Package hu.akarnokd.rxjava2.interop

Class FlowTestSubscriber<T>

  • Type Parameters:
    T - the input value type
    All Implemented Interfaces:
    io.reactivex.disposables.Disposable, io.reactivex.FlowableSubscriber<T>, java.util.concurrent.Flow.Subscriber<T>, Subscriber<T>, Subscription
    public class FlowTestSubscriber<T>
extends io.reactivex.subscribers.TestSubscriber<T>
implements java.util.concurrent.Flow.Subscriber<T>
    A TestSubscriber also extending the Flow.Subscriber interface for testing Flow.Publishers.
    Since:
    0.1.0

    • Nested Class Summary

      • Nested classes/interfaces inherited from class io.reactivex.observers.BaseTestConsumer

        io.reactivex.observers.BaseTestConsumer.TestWaitStrategy

    • Field Summary

      • Fields inherited from class io.reactivex.observers.BaseTestConsumer

        checkSubscriptionOnce, completions, done, errors, establishedFusionMode, initialFusionMode, lastThread, tag, timeout, values

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void onSubscribe​(java.util.concurrent.Flow.Subscription subscription)  

      • Methods inherited from class io.reactivex.subscribers.TestSubscriber

        assertNotSubscribed, assertOf, assertSubscribed, cancel, create, create, create, dispose, hasSubscription, isCancelled, isDisposed, onComplete, onError, onNext, onStart, onSubscribe, request, requestMore

      • Methods inherited from class io.reactivex.observers.BaseTestConsumer

        assertComplete, assertEmpty, assertError, assertError, assertError, assertErrorMessage, assertFailure, assertFailure, assertFailureAndMessage, assertNever, assertNever, assertNoErrors, assertNotComplete, assertNoTimeout, assertNotTerminated, assertNoValues, assertResult, assertTerminated, assertTimeout, assertValue, assertValue, assertValueAt, assertValueAt, assertValueCount, assertValues, assertValueSequence, assertValueSequenceOnly, assertValueSet, assertValueSetOnly, assertValuesOnly, await, await, awaitCount, awaitCount, awaitCount, awaitDone, awaitTerminalEvent, awaitTerminalEvent, clearTimeout, completions, errorCount, errors, fail, getEvents, isTerminated, isTimeout, lastThread, valueAndClass, valueCount, values, withTag

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

      • Methods inherited from interface java.util.concurrent.Flow.Subscriber

        onComplete, onError, onNext

    • Constructor Detail

      • FlowTestSubscriber

        public FlowTestSubscriber()

    • Method Detail

      • onSubscribe

        public final void onSubscribe​(java.util.concurrent.Flow.Subscription subscription)
        Specified by:
        onSubscribe in interface java.util.concurrent.Flow.Subscriber<T>