Package com.bosch.iot.dm.stream

Provides generic Stream API that allows event consumption with back-pressure and (optional) acknowledgement.

See: Description

Interface Summary

Interface	Description
Acknowledgable
StreamConsumer<T>	Consumer of event stream.
StreamHandler	Handler for event stream/channel subscription.

Class Summary

Class	Description
StreamConsumer.ClosedHandlerSupport<T>
StreamConsumer.CloseHandlerSupport<T>
StreamConsumer.ListCollector<T>
StreamConsumer.NoBackpressure<T>	Provides a consumer wrapper that, once real consumer request with negative count put the stream in no-backpressure mode.
StreamConsumer.Phoenix<T>
StreamConsumer.ProcessorAsync<T>
StreamConsumer.ProcessorSync<T>
StreamConsumer.UnionSeq<T>	Sequential iteration of streams.
StreamConsumer.VoidConsumer<T>
StreamConsumer.WrapAdapter<T>

Package com.bosch.iot.dm.stream Description

Provides generic Stream API that allows event consumption with back-pressure and (optional) acknowledgement.
The main class is StreamConsumer which is implemented by event consumers. It gets StreamHandler when opened that allows it to request events and to close stream (i.e. to cancel consumption).

Since:

1.0

Version:

1.0