code: protected Subscriber<? super R> getSubscriber() {
          Subscriber<? super R> subscriber = this.subscriber.get();
          verifyState(subscriber);
          return subscriber;
      }
docs: Get the current {@link Subscriber}.
  
  @return The {@link Subscriber}
  @throws IllegalStateException if the subscriber is not present