Interface StreamConsumer<T>
- Type Parameters:
T- type of the subscription request argument
- All Superinterfaces:
AsynchronousCloseable,AutoCloseable
Accepted stream consumer.
-
Method Summary
Modifier and TypeMethodDescriptiongetArg()onClose()Return a stage that will complete whenAsynchronousCloseable.closeAsync()is called and shutdown completes.onOpen()Returns a stage that will complete when the stream is subscribed.<E> CompletionStage<?>send(E data) Methods inherited from interface com.tick42.glue.core.AsynchronousCloseable
close, closeAsync
-
Method Details
-
getArg
T getArg() -
getCaller
Instance getCaller() -
getBranch
String getBranch() -
send
-
onOpen
CompletionStage<Void> onOpen()Returns a stage that will complete when the stream is subscribed.- Returns:
- A stage that will complete when the stream is subscribed, never
null - Since:
- 1.1
-
onClose
CompletionStage<Void> onClose()Description copied from interface:AsynchronousCloseableReturn a stage that will complete whenAsynchronousCloseable.closeAsync()is called and shutdown completes.- Specified by:
onClosein interfaceAsynchronousCloseable- Returns:
- a stage that will complete when shutdown is complete, never
null
-