deltachat::peer_channels

Function subscribe_loop

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