`.publish { o -> o.take(1).timeout(3, SECONDS)....
# rxj
jw
08/24/2018, 2:36 AM.publish { o -> o.take(1).timeout(3, SECONDS).onErrorResume(specialValue).mergeWith(o.skip(1)) }jw
08/24/2018, 2:36 AM.publish { o -> o.take(1).timeout(3, SECONDS).onErrorResume(specialValue).mergeWith(o.skip(1)) }