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 Details

    • BlockingFirstSubscriber

      public BlockingFirstSubscriber()
  • Method Details

    • onNext

      public void onNext(T t)
    • onError

      public void onError(Throwable t)