// npm install tardis-dev
const { replay } = require('tardis-dev');
const messages = replay({
exchange: 'okex-futures',
filters: [{ channel: 'futures/depth_l2_tbt', symbols: [] }],
// messages as provided by OKEx real-time stream
for await (const { localTimestamp, message } of messages) {
console.log(localTimestamp, message);