Skip to content

Conversation

@frankmcsherry
Copy link
Member

We discussed this a year back, but I couldn't recall why we didn't move it forward. I copy/pasted the code, and dressed up the documentation and examples. Worth taking a peek!

}
}
/// Convert the wrapper into a stream.
pub fn into_stream<C2>(self) -> StreamCore<S, C2>
Copy link
Member

Choose a reason for hiding this comment

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

Could S be a parameter on this function?

Copy link
Member Author

Choose a reason for hiding this comment

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

Yes, though a bit surprising. You can have an arbitrary &t T and only at this moment require that it implement Map<S, C>. I'll push it up.

@frankmcsherry frankmcsherry merged commit 1e12554 into TimelyDataflow:master Aug 28, 2025
7 checks passed
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.

2 participants