async fn subscribe_loop( context: &Context, stream: GossipReceiver, topic: TopicId, msg_id: MsgId, join_tx: Sender<()>, ) -> Result<()>