https://kotlinlang.org logo
#rx
Title
# rx
u

ursus

05/25/2018, 9:47 PM
Copy code
upstream
	.concatMap { Observable.timer(TTL)
                           .map { End() }
                           .startWith(Start())
	}
	.subscribe { status -> 
		when(status) {
			is Start -> show()
			is End -> hide()
		}
	}