Package io.servicetalk.concurrent

Interface SingleSource.Subscriber<T>

Type Parameters:
T - Type of the result of the SingleSource.
All Known Subinterfaces:
SingleSource.Processor<T,R>
All Known Implementing Classes:
TestSingleSubscriber
Enclosing interface:
SingleSource<T>
public static interface SingleSource.Subscriber<T>
Subscriber of the outcome of a SingleSource.

The semantics and threading model of this interface is meant to be the same as PublisherSource.Subscriber, but simplified for the use case where the operations completes with a single data element or fails.

  • Method Details

    • onSubscribe

      void onSubscribe(Cancellable cancellable)
      Called when the associated SingleSource is subscribed via SingleSource.subscribe(Subscriber).
      Parameters:
      cancellable - A Cancellable that can be used to cancel the asynchronous computation for this subscriber.

    • onSuccess

      void onSuccess(@Nullable T result)
      Success terminal state.

      No further events will be sent.

      Parameters:
      result - of the SingleSource.

    • onError

      void onError(Throwable t)
      Failed terminal state.

      No further events will be sent.

      Parameters:
      t - the throwable signaled.