d2.on('data', data => {
        expect(d2.queue).empty();
        expect(data).deepEqual(d1data);
        cb();
      });