public static class StreamConsumer.CloseHandlerSupport<T> extends StreamConsumer.WrapAdapter<T> implements AutoCloseable
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 |
---|
CloseHandlerSupport(StreamConsumer<T> streamConsumer) |
CloseHandlerSupport(StreamConsumer<T> streamConsumer,
CompletableFuture<StreamHandler> streamHandlerHandler) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
opened(StreamHandler handler)
Notifies that stream is opened and passes request and close handler.
|
accept, close, flush
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
authCtxAware, buffered, filterForwarder, mapForwarder, mapForwarder
public CloseHandlerSupport(StreamConsumer<T> streamConsumer)
public CloseHandlerSupport(StreamConsumer<T> streamConsumer, CompletableFuture<StreamHandler> streamHandlerHandler)
public void opened(StreamHandler handler)
StreamConsumer
opened
in interface StreamConsumer<T>
opened
in class StreamConsumer.WrapAdapter<T>
handler
- stream handlerpublic void close()
close
in interface AutoCloseable
Copyright © 2022 Bosch.IO GmbH. All rights reserved.