pub async fn send_datagrams<E: Encoder<Event, Error = Error>>(
input: &mut Peekable<BoxStream<'_, Event>>,
socket: DatagramSocket,
transformer: &Transformer,
encoder: &mut E,
bytes_sent: &<BytesSent as RegisterInternalEvent>::Handle,
)