Hello hAkkers,
In our project we use some number of flows that follow same building logic:
```
val input: Source[T, NotUsed] = ???
val output = input.runWith(BroadcastHub.sink)
output.runWith(Sink.ignore)
```
Sink.ignore here used to prevent BroadcastHub inner buffer overflow and,
also, to dump out old stream elements as they are usually do not matter.
But in some rare cases we need to provide to clients of our source 'the
last seen element' -- the last element which passed our flow before client
materialization of BroadcastHub' Source.
Currently it is done via some private volatile var:
```
@volatile private var last: Option[T] = None
_output.runForeach(e => last = Some(e))
val output = _output.prepend(Source.lazily(() => last).collect { case
Some(e} => e})
```
I wonder maybe there is better way to do so, without mutable state and
stuff?
--
>>>>>>>>>> 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 [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
