sure. you could probably do `upstream.publish(u -&...
# rxj
jw
05/12/2018, 2:30 AMsure. you could probably do
upstream.publish(u -> merge(timer().map(specialFoo).takeUntil(u), u.take(1)).retryWhen { true })