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

Fix documentation for Unzip class (#23333) (#23334)

Browse source
This commit is contained in:
Jim Riordan 2017-07-11 22:30:52 +10:00 • committed by Arnout Engelen
parent 05c7975dc0
commit c7ac498520
1 changed files with 15 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

20
akka-stream/src/main/scala/akka/stream/scaladsl/Graph.scala
View file

@ -877,9 +877,9 @@ object ZipWith extends ZipWithApply
*
* An `Unzip` has one `in` port and one `left` and one `right` output port.
*
* '''Emits when''' all of the outputs stops backpressuring and there is an input element available
* '''Emits when''' all of the outputs stop backpressuring and there is an input element available
*
* '''Backpressures when''' any of the outputs backpressures
* '''Backpressures when''' any of the outputs backpressure
*
* '''Completes when''' upstream completes
*
@ -893,7 +893,17 @@ object Unzip {
}
/**
* Combine the elements of multiple streams into a stream of the combined elements.
* Takes a stream of pair elements and splits each pair to two output streams.
*
* An `Unzip` has one `in` port and one `left` and one `right` output port.
*
* '''Emits when''' all of the outputs stop backpressuring and there is an input element available
*
* '''Backpressures when''' any of the outputs backpressure
*
* '''Completes when''' upstream completes
*
* '''Cancels when''' any downstream cancels
*/
final class Unzip[A, B]() extends UnzipWith2[(A, B), A, B](ConstantFun.scalaIdentityFunction) {
override def toString = "Unzip"
@ -902,9 +912,9 @@ final class Unzip[A, B]() extends UnzipWith2[(A, B), A, B](ConstantFun.scalaIden
/**
* Transforms each element of input stream into multiple streams using a splitter function.
*
* '''Emits when''' all of the outputs stops backpressuring and there is an input element available
* '''Emits when''' all of the outputs stop backpressuring and there is an input element available
*
* '''Backpressures when''' any of the outputs backpressures
* '''Backpressures when''' any of the outputs backpressure
*
* '''Completes when''' upstream completes
*