com.iotize.android.device.device.impl.monitor

Class GenericMonitorEngine<DataType>

java.lang.Object

com.iotize.android.device.device.impl.monitor.GenericMonitorEngine<DataType>

All Implemented Interfaces:

MonitorEngine<DataType>

public class GenericMonitorEngine<DataType>
extends java.lang.Object
implements MonitorEngine<DataType>

Nested Class Summary

Nested classes/interfaces inherited from interface com.iotize.android.device.device.api.monitor.MonitorEngine

MonitorEngine.Options

Constructor Summary

Constructors

Constructor and Description
GenericMonitorEngine(java.util.concurrent.Callable<DataType> puller)

Method Summary

Modifier and Type	Method and Description
io.reactivex.Observable<java.lang.Object>	events() Event stream
void	pause() Pause monitoring
GenericMonitorEngine<DataType>	setDefaultOptions(MonitorEngine.Options defaultOptions)
io.reactivex.Observable<DataType>	start() Start value acquisition
io.reactivex.Observable<DataType>	start(MonitorEngine.Options options) Start value acquisition with options
void	stop() Stop monitoring It will terminates values and event streams (complete will be called on your subsriptions)
io.reactivex.Observable<DataType>	values() Acquisition value stream

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GenericMonitorEngine

public GenericMonitorEngine(@NonNull
                            java.util.concurrent.Callable<DataType> puller)

Method Detail

setDefaultOptions

public GenericMonitorEngine<DataType> setDefaultOptions(@NonNull
                                                        MonitorEngine.Options defaultOptions)

start

public io.reactivex.Observable<DataType> start()

Description copied from interface: MonitorEngine

Start value acquisition

Specified by:

start in interface MonitorEngine<DataType>

start

public io.reactivex.Observable<DataType> start(@NonNull
                                               MonitorEngine.Options options)

Description copied from interface: MonitorEngine

Start value acquisition with options

Specified by:

start in interface MonitorEngine<DataType>

stop

public void stop()

Description copied from interface: MonitorEngine

Stop monitoring It will terminates values and event streams (complete will be called on your subsriptions)

Specified by:

stop in interface MonitorEngine<DataType>

pause

public void pause()

Description copied from interface: MonitorEngine

Pause monitoring

Specified by:

pause in interface MonitorEngine<DataType>

values

@NonNull
public io.reactivex.Observable<DataType> values()

Description copied from interface: MonitorEngine

Acquisition value stream

Specified by:

values in interface MonitorEngine<DataType>

events

@NonNull
public io.reactivex.Observable<java.lang.Object> events()

Description copied from interface: MonitorEngine

Event stream

Specified by:

events in interface MonitorEngine<DataType>