Hey guys Could you think of a better solution for emitting a kotlinlang #rx

Channels

100daysofkotlin

100daysofkotlin-2021

algolialibraries

android-architecture

android-databinding

androidgithubprojects

androidx-xprocessing

arrow-contributors

beepiz-libraries

cincinnati-user-group

codemash-precompiler

codingconventions

competitive-programming

competitivecoding

compose-android

compose-desktop

compose-ui-showcase

connect-audit-events

cscenter-course-2016

domain-driven-design

effective-kotlin

effectivekotlin

embedded-kotlin

event21-community-content

fb-internal-demo

fluid-libraries

framework-elide

getting-started

github-workflows-kt

graviton-browser

image-processing

intellij-plugins

intellij-tricks

introduce-yourself

java-to-kotlin-refactoring

jhipster-kotlin

jvm-ir-backend-feedback

k2-early-adopters

kotest-contributors

kotlin-by-example

kotlin-data-storage

kotlin-foundation

kotlin-in-action

kotlin-multiplatform-contest

kotlin-pakistan

kotlinforbeginners

kotlingforbeginners

kotlinprogrammers

kotlintest-devs

kotlinultimatechallenge

kotlinx-datetime

lambdaworld_cadiz

language-evolution

language-proposals

leedskotlinusergroup

library-development

machinelearningbawas

myndocs-oauth2-server

navigation-architecture-component

ohio-kotlin-users

pattern-matching

pocketgitclient

practical-functional-programming

prozis-android-backup

python-contributors

realworldkotlin

refactoring-to-kotlin

refreshversions

russian-kotlinasfirst

skia-wasm-interop-temp

sofl-user-group

spring-security

squarelibraries

stayhungrystayfoolish

strife-discord-lib

swagger-gradle-codegen

swiss-user-group

tricity-kotlin-user-group

Title

y

yougin

04/15/2020, 12:13 PM

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.

z

Zach Klippenstein (he/him) [MOD]

04/15/2020, 2:28 PM

I think you could use ~~andThen~~

concat

to keep the ordering a little more natural.

y

yougin

04/15/2020, 2:28 PM

isn’t

andThen

for

Completable

only?

z

Zach Klippenstein (he/him) [MOD]

04/15/2020, 3:06 PM

sorry,

concat

y

yougin

04/15/2020, 3:07 PM

that’s a good point, thank you

u

ursus

04/15/2020, 9:55 PM

maybe this? `

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

just make sure to refcount the source if its cold

y

yougin

04/16/2020, 9:15 AM

thanks, Vlastimil, it looks like an option too.