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 Detail

      • BlockingLastSubscriber

        public BlockingLastSubscriber()
    • Method Detail

      • onNext

        public void onNext​(T t)
      • onError

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