const udpToReadableStream = require('udp-to-readable-stream');
const crypto = require('crypto');
 
const chunks = [
  crypto.randomBytes(Math.round(Math.random() * 256)),
  crypto.randomBytes(Math.round(Math.random() * 256)),
  crypto.randomBytes(Math.round(Math.random() * 256)),
  crypto.randomBytes(Math.round(Math.random() * 256)),
];
 
const port = Math.round(10000 + 10000 * Math.random());
const socket = dgram.createSocket({ type: 'udp4', reuseAddr: true });
const stream = udpToReadableStream(port, '127.0.0.1', { type: 'udp4', reuseAddr: true });
 
stream.on('data', (chunk) => {
  console.log(`Chunk with length ${chunk.length}`);
});
 
stream.on('error', (error) => {
  console.error(error);
});
 
stream.on('close', () => {
  console.log("Close");
});
 
for (const chunk of chunks) {
  socket.send(chunk, 0, chunk.length, port, '127.0.0.1');
}
 
stream.destroy(); // Destroying the stream closes the socket
socket.close();