Switched to ws web socket implementation and can now pipe node received on a websocket into a pipeline