public static class StreamConsumer.ClosedHandlerSupport<T> extends StreamConsumer.WrapAdapter<T>
StreamConsumer.ClosedHandlerSupport<T>, StreamConsumer.CloseHandlerSupport<T>, StreamConsumer.ListCollector<T>, StreamConsumer.NoBackpressure<T>, StreamConsumer.Phoenix<T>, StreamConsumer.ProcessorAsync<T>, StreamConsumer.ProcessorSync<T>, StreamConsumer.UnionSeq<T>, StreamConsumer.VoidConsumer<T>, StreamConsumer.WrapAdapter<T>
handler, streamConsumer
Constructor and Description |
---|
ClosedHandlerSupport(StreamConsumer<T> streamConsumer) |
ClosedHandlerSupport(StreamConsumer<T> streamConsumer,
CompletableFuture<Void> closedHandler) |
Modifier and Type | Method and Description |
---|---|
void |
close(Throwable error)
Closes the consumer with
null on normal, not exceptional, close
or with an error on abnormal close. |
CompletionStage<Void> |
closedHandler() |
accept, flush, opened
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
authCtxAware, buffered, filterForwarder, mapForwarder, mapForwarder
public ClosedHandlerSupport(StreamConsumer<T> streamConsumer)
public ClosedHandlerSupport(StreamConsumer<T> streamConsumer, CompletableFuture<Void> closedHandler)
public CompletionStage<Void> closedHandler()
public void close(Throwable error)
StreamConsumer
null
on normal, not exceptional, close
or with an error on abnormal close.close
in interface StreamConsumer<T>
close
in class StreamConsumer.WrapAdapter<T>
error
- null
if normal close or an error if abnormal termination occurred.Copyright © 2022 Bosch.IO GmbH. All rights reserved.