Module methanol.testing
Package com.github.mizosoft.methanol.testing

Class TestSubscriber<T>

java.lang.Object
com.github.mizosoft.methanol.testing.TestSubscriber<T>
All Implemented Interfaces:
Flow.Subscriber<T>
public class TestSubscriber<T> extends Object implements Flow.Subscriber<T>
A Flow.Subscriber implementation that facilitates testing Flow.Publisher implementations and the like.

  • Constructor Details

    • TestSubscriber

      public TestSubscriber()

  • Method Details

    • nextCount

      public int nextCount()

    • completionCount

      public int completionCount()

    • errorCount

      public int errorCount()

    • throwOnSubscribeAndOnNext

      public TestSubscriber<T> throwOnSubscribeAndOnNext(boolean on)

    • throwOnSubscribe

      public TestSubscriber<T> throwOnSubscribe(boolean on)

    • throwOnNext

      public TestSubscriber<T> throwOnNext(boolean on)

    • autoRequest

      public TestSubscriber<T> autoRequest(long n)

    • onSubscribe

      public void onSubscribe(Flow.Subscription subscription)
      Specified by:
      onSubscribe in interface Flow.Subscriber<T>

    • onNext

      public void onNext(T item)
      Specified by:
      onNext in interface Flow.Subscriber<T>

    • onError

      public void onError(Throwable throwable)
      Specified by:
      onError in interface Flow.Subscriber<T>

    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface Flow.Subscriber<T>

    • awaitSubscription

      public Flow.Subscription awaitSubscription()

    • awaitSubscription

      public Flow.Subscription awaitSubscription(Duration timeout)

    • requestItems

      public void requestItems(long n)

    • peekAvailable

      public List<T> peekAvailable()

    • pollAll

      public List<T> pollAll()

    • pollNext

      public T pollNext()

    • pollNext

      public List<T> pollNext(int n)

    • pollNext

      public List<T> pollNext(int n, Duration timeout)

    • awaitCompletion

      public void awaitCompletion()

    • awaitCompletion

      public void awaitCompletion(Duration timeout)

    • awaitError

      public Throwable awaitError()

    • awaitError

      public Throwable awaitError(Duration timeout)