Uses of Interface
com.bosch.iot.dm.stream.StreamConsumer

Packages that use StreamConsumer

Package	Description
com.bosch.iot.dm.devices	Provides Device Inventory APIs for device management including monitoring device states and configurations listing, filtering and grouping devices instant execution of management actions over the manageable devices in a convenient way device states changes notifications
com.bosch.iot.dm.devices.groups	Defines Group Inventory APIs to organize devices in statically or dynamically defined custom groups.
com.bosch.iot.dm.devices.remote	Provides Device Inventory Remote interface
com.bosch.iot.dm.mme	Provides Mass Management Engine APIs for managing devices in a mass and automated way.
com.bosch.iot.dm.stream	Provides generic Stream API that allows event consumption with back-pressure and (optional) acknowledgement.

Uses of StreamConsumer in com.bosch.iot.dm.devices

Methods in com.bosch.iot.dm.devices with parameters of type StreamConsumer

Modifier and Type	Method and Description
void	EventSubscriptions.subscribeForDeviceEvents(Options.DeviceOptions options, StreamConsumer<DeviceEvent> consumer) Subscribe for device state events.
void	EventSubscriptions.subscribeForDeviceOfflineEvents(Optional<String> deviceId, StreamConsumer<DeviceOfflineEvent> consumer) Subscribe for device offline events.
void	EventSubscriptions.subscribeForDeviceOnlineEvents(Optional<String> deviceId, StreamConsumer<DeviceOnlineEvent> consumer) Subscribe for device online events.
void	EventSubscriptions.subscribeForDeviceStatusChangeEvents(Optional<String> deviceId, StreamConsumer<DeviceStatusChangeEvent> consumer) Subscribe for device status (offline/online) change events.
void	EventSubscriptions.subscribeForFeatureEvents(Options.FeatureOptions options, StreamConsumer<FeatureEvent> consumer) Subscribe for feature events.
void	EventSubscriptions.subscribeForFeaturePropertyEvents(Options.FeaturePropertyOptions options, StreamConsumer<FeaturePropertyEvent> consumer) Subscribe for feature property events.
void	EventSubscriptions.subscribeForLiveMessages(Options.LiveMessageOptions options, StreamConsumer<LiveMessage> consumer) Subscribe for live messages.
void	EventSubscriptions.subscribeForUploadRequestEvents(Options.UploadRequestOptions options, StreamConsumer<UploadRequestEvent> consumer) Subscribe for upload request events.

Uses of StreamConsumer in com.bosch.iot.dm.devices.groups

Methods in com.bosch.iot.dm.devices.groups with parameters of type StreamConsumer

Modifier and Type	Method and Description
void	DirectoryInventory.subscribeForDirectoryEvents(List<DirectoryEvent.Type> types, StreamConsumer<DirectoryEvent> consumer) Subscribe for Directory events.
void	FilterInventory.subscribeForFilterEntryEvents(List<FilterEntryEvent.Type> types, StreamConsumer<FilterEntryEvent> consumer) Subscribe for FilterEntry events.
void	TagInventory.subscribeForTagEvents(List<TagEvent.Type> types, StreamConsumer<TagEvent> consumer) Subscribe for Tag events.

Uses of StreamConsumer in com.bosch.iot.dm.devices.remote

Methods in com.bosch.iot.dm.devices.remote with parameters of type StreamConsumer

Modifier and Type	Method and Description
<O> void	DeviceInventoryRemote.subscriptions(String sourceType, StreamConsumer<Subscription<O>> consumer)

Uses of StreamConsumer in com.bosch.iot.dm.mme

Methods in com.bosch.iot.dm.mme with parameters of type StreamConsumer

Modifier and Type	Method and Description
void	MassManagementEngine.launchTask(TaskParameters parameters, StreamConsumer<TaskEvent> consumer)
void	MassManagementEngine.subscribeForDeviceStatusEvents(List<DeviceStatusEvent.Type> eventTypes, Optional<String> deviceId, Optional<String> ruleId, Optional<String> taskId, StreamConsumer<DeviceStatusEvent> consumer) Create non-persistent subscription for DeviceStatusEvents.
void	MassManagementEngine.subscribeForRuleEvents(List<RuleEvent.Type> eventTypes, Optional<String> ruleId, StreamConsumer<RuleEvent> consumer) Create non-persistent subscription for RuleEvents.
void	Rule.subscribeForRuleEvents(List<RuleEvent.Type> eventTypes, StreamConsumer<RuleEvent> consumer)
void	MassManagementEngine.subscribeForTaskEvents(List<TaskEvent.Type> eventTypes, Optional<String> taskId, Optional<String> ruleId, StreamConsumer<TaskEvent> consumer) Create non-persistent subscription for TaskEvents
void	Rule.subscribeForTaskEvents(List<TaskEvent.Type> eventTypes, StreamConsumer<TaskEvent> consumer)
void	Task.subscribeForTaskEvents(List<TaskEvent.Type> eventTypes, StreamConsumer<TaskEvent> consumer)

Uses of StreamConsumer in com.bosch.iot.dm.stream

Classes in com.bosch.iot.dm.stream that implement StreamConsumer

Modifier and Type	Class and Description
static class	StreamConsumer.ClosedHandlerSupport<T>
static class	StreamConsumer.CloseHandlerSupport<T>
static class	StreamConsumer.ListCollector<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.
static class	StreamConsumer.Phoenix<T>
static class	StreamConsumer.ProcessorAsync<T>
static class	StreamConsumer.ProcessorSync<T>
static class	StreamConsumer.UnionSeq<T> Sequential iteration of streams.
static class	StreamConsumer.VoidConsumer<T>
static class	StreamConsumer.WrapAdapter<T>

Fields in com.bosch.iot.dm.stream declared as StreamConsumer

Modifier and Type	Field and Description
protected StreamConsumer<T>	StreamConsumer.WrapAdapter.streamConsumer

Methods in com.bosch.iot.dm.stream that return StreamConsumer

Modifier and Type	Method and Description
default StreamConsumer<T>	StreamConsumer.authCtxAware() Creates a consumer that keeps authentication context of its creation (if present) and calls methods of this with in contexts.
default StreamConsumer<T>	StreamConsumer.buffered(int bufferSize) Creates new consumer that requests multiple events at once in order to allow the stream to re-deliver request more effectively.
default StreamConsumer<T>	StreamConsumer.filterForwarder(Predicate<T> filter) Creates new consumer that reads events from a stream, filter them using filter predicate and forwards them to this stream.
default <U> StreamConsumer<U>	StreamConsumer.mapForwarder(Function<U,T> mapper) Creates new consumer that reads events from a stream and forwards them (mapping them with the mapper function) to this stream without skipping errors.
default <U> StreamConsumer<U>	StreamConsumer.mapForwarder(Function<U,T> mapper, boolean skipErrors) Creates new consumer that reads events from a stream and forwards them (mapping them with the mapper function) to this stream.

Method parameters in com.bosch.iot.dm.stream with type arguments of type StreamConsumer

Modifier and Type	Method and Description
void	StreamConsumer.Phoenix.start(Consumer<StreamConsumer<T>> stream)

Constructors in com.bosch.iot.dm.stream with parameters of type StreamConsumer

Constructor and Description
ClosedHandlerSupport(StreamConsumer<T> streamConsumer)
ClosedHandlerSupport(StreamConsumer<T> streamConsumer, CompletableFuture<Void> closedHandler)
CloseHandlerSupport(StreamConsumer<T> streamConsumer)
CloseHandlerSupport(StreamConsumer<T> streamConsumer, CompletableFuture<StreamHandler> streamHandlerHandler)
NoBackpressure(StreamConsumer<T> streamConsumer, int onNoBackpressureInitallRequested)
Phoenix(StreamConsumer<T> consumer, BiConsumer<Runnable,Long> scheduler)
Phoenix(StreamConsumer<T> consumer, BiConsumer<Runnable,Long> scheduler, org.apache.logging.log4j.Logger log)
Phoenix(StreamConsumer<T> consumer, int startMS, int stepMS, int maxMS, BiConsumer<Runnable,Long> scheduler)
Phoenix(StreamConsumer<T> consumer, int startMS, int stepMS, int maxMS, BiConsumer<Runnable,Long> scheduler, org.apache.logging.log4j.Logger log)
UnionSeq(Iterator<Consumer<StreamConsumer<T>>> streamIterator, StreamConsumer<T> target)
WrapAdapter(StreamConsumer<T> streamConsumer)

Constructor parameters in com.bosch.iot.dm.stream with type arguments of type StreamConsumer

Constructor and Description
UnionSeq(Iterator<Consumer<StreamConsumer<T>>> streamIterator, StreamConsumer<T> target)