RockyRoad.java

        observable.let {
            stream ->
            if(someState)
                stream
            else
                stream.filter { obj -> condition(obj) }
        }
        .debounce(3, TimeUnit.SECONDS)
        .let{
            stream ->
            when(otherState){
                STATE_1 -> stream.mergeWith(otherStream)
                STATE_2 -> stream.mergeWith(secondStream)
                STATE_3 -> stream.debounce(3, TimeUnit.SECONDS);
                else -> stream
            }
        }
        .subscribe{
            //do something
        }