-
Notifications
You must be signed in to change notification settings - Fork 8
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Added unbounded memory channels #37
Conversation
Hey thanks for the PR. Is there some backstory on the reason for this PR? |
I'm using |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
If we want to merge this, we should make sure that MemoryDuplex
also works with the unbounded versions you introduced. Probably something like this
pub struct MemoryDuplex<Si, St> {
sink: Si,
stream: St
}
Co-authored-by: th4s <[email protected]>
@th4s Would an |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm modulo the function doc. Thanks!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ty!
This PR adds unbounded memory channels in the helpers, wrapping
mpsc::UnboundedSender
andmpsc::UnboundedReceiver
.