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