public static class StreamConsumer.VoidConsumer<T> extends Object implements StreamConsumer<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>
Constructor and Description |
---|
VoidConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
accept(T next)
Consumes an event.
|
void |
close(Throwable error)
Closes the consumer with
null on normal, not exceptional, close
or with an error on abnormal close. |
void |
opened(StreamHandler handler)
Notifies that stream is opened and passes request and close handler.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
authCtxAware, buffered, filterForwarder, flush, mapForwarder, mapForwarder
public void opened(StreamHandler handler)
StreamConsumer
opened
in interface StreamConsumer<T>
handler
- stream handlerpublic void accept(T next)
StreamConsumer
public void close(Throwable error)
StreamConsumer
null
on normal, not exceptional, close
or with an error on abnormal close.close
in interface StreamConsumer<T>
error
- null
if normal close or an error if abnormal termination occurred.Copyright © 2022 Bosch.IO GmbH. All rights reserved.