public interface MonitorEngine<DataType>
Modifier and Type | Interface and Description |
---|---|
static class |
MonitorEngine.Options |
Modifier and Type | Method and Description |
---|---|
io.reactivex.Observable<java.lang.Object> |
events()
Event stream
|
void |
pause()
Pause monitoring
|
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
|
io.reactivex.Observable<DataType> start()
io.reactivex.Observable<DataType> start(@NonNull MonitorEngine.Options options)
void stop()
void pause()
@NonNull io.reactivex.Observable<DataType> values()
@NonNull io.reactivex.Observable<java.lang.Object> events()