I want to zip three streams together and form a class which will be output
to a sink. however, this class should only be emitted when the first stream
emits an item, instead taking the two latest items emitted by the other
streams. Is there a way to do this in Akka? I can get it working in rxscala
with:
val stream1 = Observable.interval(Duration(3,SECONDS))
val stream2 = Observable.interval(Duration(5,SECONDS))
val stream3 = Observable.interval(Duration(7,SECONDS))
val zippedStream = stream1.combineLatest(stream2.combineLatest(stream3))
val finalStream = zippedStream.distinctUntilChanged{ case (obj,_) => obj.id
} //only emits when there is an object with a different id than the last
for stream1.
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
