Package io.servicetalk.concurrent
Interface CompletableSource
-
- All Known Subinterfaces:
CompletableSource.Processor
- All Known Implementing Classes:
NettyFutureCompletable
,RunnableCompletable
,SubscribableCompletable
,TestCompletable
- 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
ACompletableSource.Processor
represents a processing stage that is both aCompletableSource
and aCompletableSource.Subscriber
and obeys the contracts of both.static interface
CompletableSource.Subscriber
Subscriber of the outcome of aCancellable
.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
subscribe(CompletableSource.Subscriber subscriber)
Subscribes to the outcome of thisCompletableSource
.
-
-
-
Method Detail
-
subscribe
void subscribe(CompletableSource.Subscriber subscriber)
Subscribes to the outcome of thisCompletableSource
.- Parameters:
subscriber
- of the outcome.- See Also:
PublisherSource.subscribe(PublisherSource.Subscriber)
-
-