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 65c5b9c commit c3b2944Copy full SHA for c3b2944
capnp-rpc/examples/pubsub/server.rs
@@ -162,7 +162,7 @@ pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
162
while let Some(()) = rx.next().await {
163
let subscribers1 = subscribers.clone();
164
let subs = &mut subscribers.borrow_mut().subscribers;
165
- for (&idx, mut subscriber) in subs.iter_mut() {
+ for (&idx, subscriber) in subs.iter_mut() {
166
if subscriber.requests_in_flight < 5 {
167
subscriber.requests_in_flight += 1;
168
let mut request = subscriber.client.push_message_request();
0 commit comments