Skip to content

+str Add combine seq method to Source and Sink.#849

Merged
He-Pin merged 1 commit intoapache:mainfrom
He-Pin:combineSeq
Dec 18, 2023
Merged

+str Add combine seq method to Source and Sink.#849
He-Pin merged 1 commit intoapache:mainfrom
He-Pin:combineSeq

Conversation

@He-Pin
Copy link
Copy Markdown
Member

@He-Pin He-Pin commented Dec 17, 2023

Origin issue refs: akka/akka-core#23958

/**
* Combine two sinks with fan-out strategy like `Broadcast` or `Balance` and returns `Sink` with 2 outlets.
*/
def combineMat[T, U, M1, M2, M](
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

can you add @since 1.1.0 to the new public methods?

@mdedetrich
Copy link
Copy Markdown
Contributor

lgtm, but add the @since as @pjfanning mentioned.

Copy link
Copy Markdown
Member

@pjfanning pjfanning left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants