I'm working with an OutputStreamSink
(http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-RC3/index.html#akka.stream.io.OutputStreamSink$)
which materializes a Future[Long]. I'd like to use an OutputStreamSink as
part of a flow, but I can't get the types to line up.
Ideally my graph will look something like this; it splits an input stream,
zips the result, and checker checks to make sure the future[long]'s are
equal.
```
in ~> broadcast ~> outputsink1 ~> zip.in0 ~> checker
~> broadcast ~> outputsink2 ~> zip.in1
```
any ideas? It seems like I need to rewrite OutputStreamSink from a Sink to
a Flow, or use a SubscriberActor with a PublisherActor, or possibly write
some sort of PushPullStage. Seems like there should be an easy way to
"lift" a sink with a materialized value to a flow stage.
Thanks,
Mike
--
>>>>>>>>>> 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 http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
