``` upstream .concatMap { Observable.timer(TTL) ...

# rx

[ursus]

upstream
	.concatMap { Observable.timer(TTL)
                           .map { End() }
                           .startWith(Start())
	}
	.subscribe { status -> 
		when(status) {
			is Start -> show()
			is End -> hide()
		}
	}