code: @Override
      public T drain() {
          T event = delayed.drain();
          if (event != null) {
              return event;
          }
  
          return source.drain();
      }
docs: Ignore any scheduled delays and return events in
  schedule order until empty.