Sets up a simple udp receiver which pushes received udp messages onto a readstream as objects containing the received message, info about the remote client, and a reply function.
var udp_server = require('udp2stream')
var through2 = require('through2')
var reply_to_request = through2.obj(function (udp, _, next) {
console.log('Received message ' + udp.request.message.toString() + ' from ' + udp.request.client.address + ':' + udp.request.client.port)
udp.reply('This is my reply to the client')
this.push(udp)
next()
})
var server = udp_server.listen({port: 1234})
server
.pipe(reply_to_request)
.on('data', function (data) {
console.log(data)
})
.on('error', function (error) {
console.log(error)
})
setTimeout(function () {
// close the server
server.close()
}, 10000)
- options.port: udp_port to bind to
- options.address: udp_address to bind to
Stop listening, close server.