fn spawn()

in network/src/reliable_sender.rs [126:137]

• 12 lines of code
• 1 McCabe index (conditional complexity)

    fn spawn(address: SocketAddr, receiver: Receiver<InnerMessage>) {
        tokio::spawn(async move {
            Self {
                address,
                receiver,
                retry_delay: 200,
                buffer: VecDeque::new(),
            }
            .run()
            .await;
        });
    }