Ports the listener to use the reactive library for reading packets off the wire.