BasicEmitter2.kt

class Emitter(private val stateObservable: Observable<State>) {
  
  init {
    stateObservable.subscribe { stateChanged(it) }
  }
  
  private fun stateChanged(state: State) {
    
  }
  
  fun defaultStateObservable(): Observable<Data>
  
  fun specialStateObservable(): Observable<Data>
}