public interface StreamHandler extends AutoCloseable
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the stream.
|
void |
request(int count)
Request
count more events from the stream/channel. |
void request(int count)
count
more events from the stream/channel. This allows back-pressure
for the stream/channel. If the consumer of the events don't want to use back-pressure it
may call this method with count
-1.count
- request element countvoid close()
close
in interface AutoCloseable
Copyright © 2022 Bosch.IO GmbH. All rights reserved.