Package | Description |
---|---|
com.bosch.iot.dm.stream |
Provides generic Stream API that allows event consumption with back-pressure and (optional) acknowledgement.
|
Modifier and Type | Class and Description |
---|---|
static class |
StreamConsumer.ClosedHandlerSupport<T> |
static class |
StreamConsumer.CloseHandlerSupport<T> |
static class |
StreamConsumer.NoBackpressure<T>
Provides a consumer wrapper that, once real consumer request with negative count
put the stream in no-backpressure mode.
|
Copyright © 2022 Bosch.IO GmbH. All rights reserved.