io.servicetalk.concurrent

Interface SingleSource<T>

Type Parameters:

T - Type of the result of this SingleSource.

All Known Subinterfaces:

SingleSource.Processor<T,R>

All Known Implementing Classes:

SourceWrappers.SingleSource, SubscribableSingle

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface SingleSource<T>

An asynchronous computation that either completes with success giving the result or completes with an error.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	SingleSource.Processor<T,R> A SingleSource.Processor represents a processing stage that is both a SingleSource and a SingleSource.Subscriber and obeys the contracts of both.
static interface	SingleSource.Subscriber<T> Subscriber of the outcome of a SingleSource.

Method Summary

Modifier and Type	Method and Description
void	subscribe(SingleSource.Subscriber<? super T> subscriber) Subscribe for the result of this SingleSource.

Method Detail

subscribe

void subscribe(SingleSource.Subscriber<? super T> subscriber)

Subscribe for the result of this SingleSource.

Parameters:

subscriber - to subscribe for the result.

See Also:

PublisherSource.subscribe(PublisherSource.Subscriber)