fn write_data()

in fastpay/src/transport.rs [32:40]

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

    fn write_data<'a>(
        &'a mut self,
        buffer: &'a [u8],
    ) -> future::BoxFuture<'a, Result<(), std::io::Error>>;
    fn read_data(&mut self) -> future::BoxFuture<Result<Vec<u8>, std::io::Error>>;
}

/// A pool of (outgoing) data streams.
pub trait DataStreamPool: Send {