Am I reading this correctly that reaktive does not...

# reaktive

[saket]

Am I reading this correctly that reaktive does not freeze items emitted by a Source?

subscribeOn freezes both its upstream source and downstream observer, all the Disposables (upstream’s and downstream’s) are frozen as well, all the values (including errors) are not frozen by the operator

I’m consuming an Observable from k/native, and I wanted to confirm that doing this is expected:

upstream.map {  it.freeze() }

[Arkadii Ivanov]

Actually operators do not freeze anything, but schedulers do. The subscribeOn operator affects only the subscription phase, so it does not freeze emitted values. But observeOn affects emission, and it does freeze values.

[Arkadii Ivanov]

Why do you need to freeze values manually?

[saket]

Ah I feel stupid to miss the next paragraph where this was mentioned:

observeOn freezes only its downstream observer and all the values (including errors) passed through it, plus all the Disposables, upstream source is not frozen by the operator

[saket]

Why do you need to freeze values manually?

I’m letting consuming platforms, android and macOS, control the thread where the emissions are observed, which explains why my emissions weren’t getting auto-frozen.