strong-tie/inbound-calls

1var tape = require('tape')2var through = require('through2')3var stream = require('stream')4var shift = require('./')5 6tape('shifts next', function (t) {7  var passthrough = through()8 9  passthrough.write('hello')10  passthrough.write('world')11 12  t.same(shift(passthrough), Buffer.from('hello'))13  t.same(shift(passthrough), Buffer.from('world'))14  t.end()15})16 17tape('shifts next with core', function (t) {18  var passthrough = stream.PassThrough()19 20  passthrough.write('hello')21  passthrough.write('world')22 23  t.same(shift(passthrough), Buffer.from('hello'))24  t.same(shift(passthrough), Buffer.from('world'))25  t.end()26})27 28tape('shifts next with object mode', function (t) {29  var passthrough = through({objectMode: true})30 31  passthrough.write({hello: 1})32  passthrough.write({world: 1})33 34  t.same(shift(passthrough), {hello: 1})35  t.same(shift(passthrough), {world: 1})36  t.end()37})38 39tape('shifts next with object mode with core', function (t) {40  var passthrough = stream.PassThrough({objectMode: true})41 42  passthrough.write({hello: 1})43  passthrough.write({world: 1})44 45  t.same(shift(passthrough), {hello: 1})46  t.same(shift(passthrough), {world: 1})47  t.end()48})49