`just(1, 2, 3)` -> `flowOf(1, 2, 3)` `error(Exception())` -> `flow { throw Exception() }`

# coroutines

[jw]

just(1, 2, 3) -> flowOf(1, 2, 3)
error(Exception()) -> flow { throw Exception() }

[Timo Obereder]

Sorry to start a thread here, but i got another one. What would be the equivalent for Observable.create? Also this is probably use case specific. Let’s say i would want a thread to wait and then throw an error after a few seconds

flow { 
            try {
                Thread.sleep(3000)
            } catch (e: InterruptedException) {
                e.printStackTrace()
            }
            this.emit(throw whateverException)
}

[jw]

Change Thread.sleep to delay

[Timo Obereder]

oh, yeah, sry

[Timo Obereder]

thanks

[jw]

RxJava has a delaySubscription operator but I don't think there's a flow equivalent

[Timo Obereder]

im also not sure about the throw, could i leave it out?

[jw]

you would either throw or emit

[Timo Obereder]

ok, so leaving it out then

[Timo Obereder]

Okay, i have another question, is there an equivalent to RxJava doOnNext and doOnComplete? Flow.onEach?

[louiscad]

There are the delayEach and the delayFlow operators.