Package 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	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	Description
void	subscribe(SingleSource.Subscriber<? super T> subscriber)	Subscribe for the result of this SingleSource.

Method Details

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)