tangled
alpha
login
or
join now
stream.place
/
streamplace
Live video on the AT Protocol
74
fork
atom
overview
issues
1
pulls
pipelines
moar logging -v
b5
3 months ago
a2671c4f
bf6abe3f
+3
1 changed file
expand all
collapse all
unified
split
rust
iroh-streamplace
src
lib.rs
+3
rust/iroh-streamplace/src/lib.rs
···
507
..
508
} = msg;
509
let conn = self.connections.get(&remote_id);
0
510
conn.rpc
511
.rpc(rpc::Subscribe {
512
key: key.clone(),
···
514
})
515
.await
516
.ok();
0
517
self.subscriptions.insert(key, remote_id);
518
tx.send(()).await.ok();
0
519
}
520
ApiMessage::Unsubscribe(msg) => {
521
trace!(inner = ?msg.inner, "ApiMessage::Unsubscribe");
···
507
..
508
} = msg;
509
let conn = self.connections.get(&remote_id);
510
+
trace!(remote = %remote_id.fmt_short(), key = %key, "send rpc::Subscribe message");
511
conn.rpc
512
.rpc(rpc::Subscribe {
513
key: key.clone(),
···
515
})
516
.await
517
.ok();
518
+
trace!(remote = %remote_id.fmt_short(), key = %key, "inserting subscription");
519
self.subscriptions.insert(key, remote_id);
520
tx.send(()).await.ok();
521
+
trace!("finished inserting subscription");
522
}
523
ApiMessage::Unsubscribe(msg) => {
524
trace!(inner = ?msg.inner, "ApiMessage::Unsubscribe");