These are synchronous implementations, because we need to be Java 6 compatible while developing on 2.3.x. However asynchronous implementations using AsynchronousFileChannel will come soon for JDK7 users. + ActorPublisher/Subscriber now manage stopping of the actor + added documentation on configuring dispatcher for File IO + properly handle if source file does not exist + file sink / source come with default io dispatcher > verified no actors are leaking > exceptions are caught and onErrored properly + moved files to akka.stream.io + Added OutputStreamSink and InputStreamSource |
||
|---|---|---|
| .. | ||
| stream-customize.rst | ||
| stream-error.rst | ||
| stream-flows-and-basics.rst | ||
| stream-graphs.rst | ||
| stream-index.rst | ||
| stream-integrations.rst | ||
| stream-introduction.rst | ||
| stream-io.rst | ||
| stream-quickstart.rst | ||
| stream-rate.rst | ||