raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

=doc #17291 more stream test docs

Browse source
This commit is contained in:
Martynas Mickevičius 2015-06-19 10:03:55 +03:00
parent b4272b77c2
commit 27dd698706
3 changed files with 191 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala
View file

@ -328,9 +328,9 @@ object Source extends SourceApply {
* if there is no demand from downstream. When `bufferSize` is 0 the `overflowStrategy` does
* not matter.
*
* The stream can be completed successfully by sending the actor referende an [[akka.actor.Status.Success]]
* messagein which case already buffered elements will be signalled before signalling completion,
* or by sending a [[akka.actor.PoisonPill]] in which case completion will be signalled immediatly.
* The stream can be completed successfully by sending the actor reference an [[akka.actor.Status.Success]]
* message in which case already buffered elements will be signalled before signalling completion,
* or by sending a [[akka.actor.PoisonPill]] in which case completion will be signalled immediately.
*
* The stream can be completed with failure by sending [[akka.actor.Status.Failure]] to the
* actor reference. In case the Actor is still draining its internal buffer (after having received