code: protected Optional<Subscriber<? super R>> currentSubscriber() {
          Subscriber<? super R> subscriber = this.subscriber.get();
          return Optional.ofNullable(subscriber);
      }
docs: Get the current {@link Subscriber}.
  
  @return An {@link Optional} subscriber