public interface GetEventStream<DataType,EventType>
io.reactivex.Observable<Event<DataType,EventType>>
getEventStreams()
io.reactivex.Observable<Event<DataType,EventType>> getEventStreams()