private val viewStateSubject: BehaviorSubject<StateT> = BehaviorSubject.create()

viewStateDisposable = viewStateSubject
            .defaultIfEmpty(createInitialState())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(view::switchToState)

private val viewStateSubject: BehaviorSubject<StateT> = BehaviorSubject.createDefault(createInitialState())