Hi all- Seems like it should be simple, so I'm just missing something obvious. The various pages around the Internet are no help (for instance, FoldSink seems to be gone in RC2).
My entire code is here: https://gist.github.com/dudehook/c92541a353293eb36a9e The relevant portion is: def run = { val f = new File("dave.test") val filePub = Source.synchronousFile(f, 512) val fs = SynchronousFileSource(f, 512) val ftes= Flow[ByteString].transform { () => parseLines("/n", 1024 ) } val output = new StringBuilder val sink = Sink.fold(output)((acc: StringBuilder, s:String) => { println(s"s: $s") acc.append(s) }) val all = fs.via(ftes).runWith(sink).map[String] { b: StringBuilder => b.toString() } Await.ready(all, 5 seconds) (all.value, output.toString()) } When I run on REPL, I get a *(Option[scala.util.Try[String]], String) = (Some(Success()),"")* The strings are always empty. The "Got chunk" message within the parseLines function does print once, so I know it's processing something. Any ideas? Seems like akka-streams is a moving target, but I really want to use it for this... could end up being core to something bigger. -- >>>>>>>>>> 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.
