Class BlockingFirstSubscriber<T>

  • Type Parameters:
    T - the value type
    All Implemented Interfaces:
    FlowableSubscriber<T>, org.reactivestreams.Subscriber<T>

    public final class BlockingFirstSubscriber<T>
    extends BlockingBaseSubscriber<T>
    Blocks until the upstream signals its first value or completes.
    • Constructor Detail

      • BlockingFirstSubscriber

        public BlockingFirstSubscriber()
    • Method Detail

      • onNext

        public void onNext​(T t)
      • onError

        public void onError​(java.lang.Throwable t)