Skip to content

Commit

Permalink
Update substrate/client/rpc-spec-v2/src/chain_head/subscription/inner.rs
Browse files Browse the repository at this point in the history
  • Loading branch information
niklasad1 authored Sep 19, 2024
1 parent 486b246 commit 67a37ce
Showing 1 changed file with 0 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -543,7 +543,6 @@ impl<Block: BlockT, BE: Backend<Block>> SubscriptionsInner<Block, BE> {
if let Entry::Vacant(entry) = self.subs.entry(sub_id) {
let (tx_stop, rx_stop) = oneshot::channel();
// We are relying on the backpressure from the underlying subscription and we shouldn't
// buffer more than the underlying client can handle.
let (response_sender, response_receiver) =
futures::channel::mpsc::channel(BUF_CAP_PER_SUBSCRIPTION);
let state = SubscriptionState::<Block> {
Expand Down

0 comments on commit 67a37ce

Please sign in to comment.