in fastpay/src/transport.rs [154:159]
fn read_data(&mut self) -> future::BoxFuture<Result<Vec<u8>, std::io::Error>> {
Box::pin(async move {
let size = self.socket.recv(&mut self.buffer).await?;
Ok(self.buffer[..size].into())
})
}