The end result of my stream is a Pair, CustomContext>
In the Sink I now want to parse the Source into Json (with a library with
needs an InputStream). I also need in the Sink a reference
to CustomContext.
I looked in Akka and found a OutputStreamSink which I think I can use as a
blueprint for
Hi everybody!
I have build a set of actors to dynamically parse files in some directory,
where could be millions of files.
I create a DirChecker actor who send filenames to be processed - just
filtering file names and have mutable Set for wrong format files.
Next I create FilesProcessor actor tha
hi,
I have simple actor producer based
on
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/java/stream-integrations.html#ActorPublisher
public class MessageProducer extends AbstractActorPublisher
{
private final static Logger logger =
LoggerFactory.getLogger(MessageProducer.cla
