We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
As prep for #5617
we need a helper stream type that makes use of the watch channel introduced in #10203
this should be a new type that wraps the receiver and emits new pending values, None values can be skipped.
None
see also:
reth/crates/chain-state/src/notifications.rs
Lines 38 to 44 in e907f0e
see also tokio_stream::WatchStream
tokio_stream::WatchStream
Ideally this stream type is generic over Option<T> so we can reuse this for the safe and finalized watchers as well
Option<T>
No response
The text was updated successfully, but these errors were encountered:
jenpaff
Successfully merging a pull request may close this issue.
Describe the feature
As prep for #5617
we need a helper stream type that makes use of the watch channel introduced in #10203
this should be a new type that wraps the receiver and emits new pending values,
None
values can be skipped.see also:
reth/crates/chain-state/src/notifications.rs
Lines 38 to 44 in e907f0e
see also
tokio_stream::WatchStream
Ideally this stream type is generic over
Option<T>
so we can reuse this for the safe and finalized watchers as wellAdditional context
No response
The text was updated successfully, but these errors were encountered: