We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e65f5d1 commit 4c62598Copy full SHA for 4c62598
src/robust_subscription.rs
@@ -194,7 +194,8 @@ impl<N: Network> RobustSubscription<N> {
194
/// and forwards items to a channel, which is then wrapped in a Stream.
195
#[must_use]
196
pub fn into_stream(mut self) -> RobustSubscriptionStream<N> {
197
- // TODO: This shouldnt be unbounded
+ // TODO: This shouldnt be unbounded need choose an appropriate bound (Maybe same as max
198
+ // buffer probably should be bigger)
199
let (tx, rx) = mpsc::unbounded_channel();
200
201
tokio::spawn(async move {
0 commit comments