Hello everyone. Is there a alternative to `ObservableTransformer` when using `Flow` or `Channel`?

# coroutines

[sasikanth]

Hello everyone. Is there a alternative to ObservableTransformer when using Flow or Channel?

[Paul Woitaschek]

An extension function

[streetsofboston]

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

[Paul Woitaschek]

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

[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.

[Paul Woitaschek]

Hm Imo a observable transformer just lets you combine existing operators

[streetsofboston]

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. 🙂

[sasikanth]

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

[sasikanth]

My use case was mainly implementing the transformer as a interface for a object/class. But extension functions also works I think.