main.rs

fn main() {
        let client = hypercore_protocol::ProtocolBuilder::initiator().connect(tcp_stream);
        let shared_client = Arc::new(async_std::sync::RwLock::new(client));

        let bg_client = shared_client.clone();
        let bg_task = task::spawn(async move {
            while let Ok(e) = bg_client.write().await.loop_next().await {
                dbg!(e);
            }
        });

        let fg_task = task::spawn(async move {
            shared_client.read().await.open(b"deadbeef".to_vec()).await;
        });
}