Hello everyone. Is there a alternative to

ObservableTransformer

when using

Flow

or

Channel

?

An extension function

For Flows, transformers, or just custom operators, look more or less like this:

fun <T> Flow<T>.myTransformer(...) = flow {
    ...
        this.collect {
            ...
            ... do your stuff whatever it is ...
                emit(it)
            ...
        }
    ...
}

You can add loops, flow control, etc, whatever you want

That's a different concept. An ObservableTransformer is more like an extension function @streetsofboston

The example I gave is an extension function. And Rx Transformers can be used to create your own custom Rx operators. And my example is a custom operator on a Flow.

Hm Imo a observable transformer just lets you combine existing operators

You can just combine other operators in the

apply

of the Transformer, like you said, but you can do a lot more funky stuff as well. 🙂

Oh yeah, this makes a lot of sense. I was trying to find a 1:1 replacement for

ObservableTransformer

. Thanks 👍🏽