Package io.servicetalk.concurrent.api.test

Interface CompletableLastStep

All Known Subinterfaces:
CompletableFirstStep
public interface CompletableLastStep
Provides the ability to express expectations for the terminal signals (e.g. onComplete or onError) of a CompletableSource.Subscriber.

  • Method Details

    • expectNoSignals

      CompletableLastStep expectNoSignals(Duration duration)
      Expect no signals in duration time.
      Parameters:
      duration - The amount of time to assert that no signals are received.
      Returns:
      An object which allows for subsequent expectations to be defined.

    • expectError

      StepVerifier expectError()
      Declare an expectation that onError will be the next signal.
      Returns:
      An object which allows to verify all expectations.

    • expectErrorMatches

      StepVerifier expectErrorMatches(Predicate<Throwable> errorPredicate)
      Declare an expectation that onError will be the next signal and evaluate it with errorPredicate.
      Parameters:
      errorPredicate - Will be invoked when onError is called and will raise a AssertionError if the predicate returns false.
      Returns:
      An object which allows to verify all expectations.

    • expectError

      StepVerifier expectError(Class<? extends Throwable> errorClass)
      Declare an expectation that onError will be the next signal and it will be of type errorClass.
      Parameters:
      errorClass - The type of error which is expected.
      Returns:
      An object which allows to verify all expectations.

    • expectErrorConsumed

      StepVerifier expectErrorConsumed(Consumer<Throwable> errorConsumer)
      Declare an expectation that onError will be the next signal and evaluate it with errorConsumer.
      Parameters:
      errorConsumer - Will be invoked when onError is called.
      Returns:
      An object which allows to verify all expectations.

    • expectComplete

      StepVerifier expectComplete()
      Declare an expectation that CompletableSource.Subscriber.onComplete() onComplete} will be the next signal.
      Returns:
      An object which allows to verify all expectations.

    • thenCancel

      StepVerifier thenCancel()
      Manually invoke Cancellable.cancel() on the Cancellable from CompletableSource.Subscriber.onSubscribe(Cancellable).
      Returns:
      An object which allows to verify all expectations.

    • then

      CompletableLastStep then(Runnable r)
      Invoke Runnable.run() on the thread which invokes StepVerifier.verify().
      Parameters:
      r - the Runnable to invoke.
      Returns:
      An object which allows for subsequent expectations to be defined.

    • thenAwait

      CompletableLastStep thenAwait(Duration duration)
      Wait for a time delay of duration on the thread which invokes StepVerifier.verify().
      Parameters:
      duration - the duration to wait for.
      Returns:
      An object which allows for subsequent expectations to be defined.