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

jw

05/12/2018, 2:30 AM
sure. you could probably do
upstream.publish(u -> merge(timer().map(specialFoo).takeUntil(u), u.take(1)).retryWhen { true })
or something