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

=str Rename method parameter name from request to segmentSize for interleaveMat. (#31527)

Browse source
This commit is contained in:
kerr 2022-09-05 15:18:20 +08:00 • committed by GitHub
parent 422a5b8dae
commit 5f87a98bc7
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

19
akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala
View file

@ -3690,9 +3690,12 @@ trait FlowOpsMat[+Out, +Mat] extends FlowOps[Out, Mat] {
* It is recommended to use the internally optimized `Keep.left` and `Keep.right` combiners
* where appropriate instead of manually writing functions that pass through one of the values.
*/
def interleaveMat[U >: Out, Mat2, Mat3](that: Graph[SourceShape[U], Mat2], request: Int)(
matF: (Mat, Mat2) => Mat3): ReprMat[U, Mat3] =
interleaveMat(that, request, eagerClose = false)(matF)
@nowarn("msg=deprecated")
def interleaveMat[U >: Out, Mat2, Mat3](
that: Graph[SourceShape[U], Mat2],
@deprecatedName(Symbol("request"))
segmentSize: Int)(matF: (Mat, Mat2) => Mat3): ReprMat[U, Mat3] =
interleaveMat(that, segmentSize, eagerClose = false)(matF)
/**
* Interleave is a deterministic merge of the given [[Source]] with elements of this [[Flow]].
@ -3710,9 +3713,13 @@ trait FlowOpsMat[+Out, +Mat] extends FlowOps[Out, Mat] {
* It is recommended to use the internally optimized `Keep.left` and `Keep.right` combiners
* where appropriate instead of manually writing functions that pass through one of the values.
*/
def interleaveMat[U >: Out, Mat2, Mat3](that: Graph[SourceShape[U], Mat2], request: Int, eagerClose: Boolean)(
matF: (Mat, Mat2) => Mat3): ReprMat[U, Mat3] =
viaMat(interleaveGraph(that, request, eagerClose))(matF)
@nowarn("msg=deprecated")
def interleaveMat[U >: Out, Mat2, Mat3](
that: Graph[SourceShape[U], Mat2],
@deprecatedName(Symbol("request"))
segmentSize: Int,
eagerClose: Boolean)(matF: (Mat, Mat2) => Mat3): ReprMat[U, Mat3] =
viaMat(interleaveGraph(that, segmentSize, eagerClose))(matF)
/**
* MergeLatest joins elements from N input streams into stream of lists of size N.