const bitfinexStreams = require('bitfinex-streams');
const { OrderBookStream } = bitfinexStreams;
 
const orderBookStream = new OrderBookStream();
 
orderBookStream.pipe(...);