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