-
Notifications
You must be signed in to change notification settings - Fork 272
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
Additional improvements to integrate pubsub with Parity #110
Conversation
macros/src/pubsub.rs
Outdated
|
||
fn start_send(&mut self, item: Self::SinkItem) -> futures::StartSend<Self::SinkItem, Self::SinkError> { | ||
if self.poll()?.is_not_ready() { | ||
return Ok(futures::AsyncSink::NotReady(item)); |
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.
does this need to schedule a Task
wakeup?
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.
I'm pretty sure it doesn't, but putting the rationale why in a comment above (since futures have a lot of hidden complexity) would help
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.
Updated!
I am not familiar with how |
Nightly failure seems unrelated to the changes. See rust-lang/rustup#1062 for more details. |
* Cloneable types * Adding Origin to RequestContext * Sink implementations. * Add comment regarding Task wakeup.
Closes #109