Package io.servicetalk.concurrent

Interface CompletableSource.Processor

All Superinterfaces:

CompletableSource, CompletableSource.Subscriber

Enclosing interface:

CompletableSource

public static interface CompletableSource.Processor
extends CompletableSource, CompletableSource.Subscriber

A CompletableSource.Processor represents a processing stage that is both a CompletableSource and a CompletableSource.Subscriber and obeys the contracts of both.

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.concurrent.CompletableSource

CompletableSource.Processor, CompletableSource.Subscriber

Method Summary

Methods inherited from interface io.servicetalk.concurrent.CompletableSource

subscribe

Methods inherited from interface io.servicetalk.concurrent.CompletableSource.Subscriber

onComplete, onError, onSubscribe