code: public boolean disposeIfNotSubscribed() {
          if (state.casState(State.STATES.UNSUBSCRIBED, State.STATES.DISPOSED)) {
              state.bufferedSubject.lift(new AutoReleaseByteBufOperator<T>()).subscribe(Subscribers.empty()); // Drain all items so that ByteBuf gets released.
              return true;
          }
          return false;
      }
docs: This will eagerly dispose this {@link Subject} without waiting for the no subscription timeout period,
  if configured.
  
  This must be invoked when the caller is sure that no one will subscribe to this subject. Any subscriber after
  this call will receive an error that the subject is disposed.
  
  @return {@code true} if the subject was disposed by this call (if and only if there was no subscription).