Search code examples
rx-scala

Transforming Observables in RxJava and RxScala

I have an Observable that emits a List of entries as below:

val obsList: Observable[List[MyEntry] = Observable.from(getListEntry)

// getListEntry would give me a List[MyEntry]

How could I now get the contents piped into another Observable that takes in a MyEntry? I mean, for each entry in the original Observable, I would need to pipe them to another Observable that has a type signature of:

Observable[MyEntry]
Solution

  • I figured out how to do this! I'm using the Monifu library!

    So, I would be doing:

    Observable.fromIterable(listOfEntry)