in fastpay/src/transport.rs [311:320]
fn send_data_to<'a>(
&'a mut self,
buffer: &'a [u8],
address: &'a str,
) -> future::BoxFuture<'a, Result<(), std::io::Error>> {
Box::pin(async move {
let stream = self.get_stream(address).await?;
TcpDataStream::tcp_write_data(stream, buffer).await
})
}