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>, Flow.Subscriber<T>, Subscriber<T>, Subscription
    public class FlowTestSubscriber<T>
extends io.reactivex.subscribers.TestSubscriber<T>
implements 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​(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