Hey guys! Could you think of a better solution for emitting an event with a delay after the first em...

# rx

[yougin]

Hey guys! Could you think of a better solution for emitting an event with a delay after the first emission from Observable?

just(1)
    .flatMap { just(2).delay(1, SECONDS).startWith(it) }
    .subscribe { println(it) }

Just curious if I’m missing on some operator which does the thing.

[Zach Klippenstein (he/him) [MOD]]

I think you could use andThen concat to keep the ordering a little more natural.

[yougin]

isn’t andThen for Completable only?

[Zach Klippenstein (he/him) [MOD]]

sorry, concat

[yougin]

that’s a good point, thank you

[ursus]

maybe this? `

Observable.merge(
   source.take(1), 
   source.skip(1).delay(..)
)

[ursus]

just make sure to refcount the source if its cold

[yougin]

thanks, Vlastimil, it looks like an option too.