Class BlockingLastSubscriber<T>

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

public final class BlockingLastSubscriber<T> extends BlockingBaseSubscriber<T>
Blocks until the upstream signals its last value or completes.
  • Constructor Details

    • BlockingLastSubscriber

      public BlockingLastSubscriber()
  • Method Details

    • onNext

      public void onNext(T t)
    • onError

      public void onError(Throwable t)