Hello everyone, I’m trying to figure out how i can...

# arrow

[streetsofboston]

Hello everyone,
I’m trying to figure out how i can use Arrow in my Rx flow.
Is there a way to have the same type of idiom when using Arrow (e.g. using a Try) as when using plain Rx?
E.g.

val plainObservable: Observable<Int> = .....
val res: Observable<Int> = plainObservable.map { x -> abs(x) }.flatMap { x -> Observables.fromIterable(List<Int>(9) { it * x }) }
...
val tryObservable: Observable<Try<Int>> = .....
val res: Observable<Try<Int>> = tryObservable.map__ { x -> abs(x) }.flatMap__ { x -> Observables__.fromIterable__(List<Int>(9) { it * x }) }

Where x is just an Int in both examples and where the methods ending in __ are some methods that work like the plain ones but only operate on values held by Try.Success.