Package io.servicetalk.concurrent

Interface CompletableSource

All Known Subinterfaces:

CompletableSource.Processor

All Known Implementing Classes:

NettyFutureCompletable, SubscribableCompletable

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 CompletableSource

An asynchronous computation that does not emit any data. It just completes or emits an error.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	CompletableSource.Processor	A CompletableSource.Processor represents a processing stage that is both a CompletableSource and a CompletableSource.Subscriber and obeys the contracts of both.
static interface	CompletableSource.Subscriber	Subscriber of the outcome of a Cancellable.

Method Summary

Modifier and Type	Method	Description
void	subscribe(CompletableSource.Subscriber subscriber)	Subscribes to the outcome of this CompletableSource.

Method Details

subscribe

void subscribe(CompletableSource.Subscriber subscriber)

Subscribes to the outcome of this CompletableSource.

Parameters:

subscriber - of the outcome.

See Also:

• PublisherSource.subscribe(PublisherSource.Subscriber)