stream-chain/tests/test_skip.js

'use strict';

const unit = require('heya-unit');

const {streamToArray, delay} = require('./helpers');
const chain = require('../src/index');

const fromIterable = require('../src/utils/fromIterable');
const skip = require('../src/utils/skip');
const skipWhile = require('../src/utils/skipWhile');

unit.add(module, [
  function test_skip(t) {
    const async = t.startAsync('test_skip');

    const output = [],
      c = chain([fromIterable([1, 2, 3, 4, 5]), skip(2), streamToArray(output)]);

    c.on('end', () => {
      eval(t.TEST('t.unify(output, [3, 4, 5])'));
      async.done();
    });
  },
  function test_skipWhile(t) {
    const async = t.startAsync('test_skipWhile');

    const output = [],
      c = chain([fromIterable([1, 2, 3, 4, 5]), skipWhile(x => x != 3), streamToArray(output)]);

    c.on('end', () => {
      eval(t.TEST('t.unify(output, [3, 4, 5])'));
      async.done();
    });
  },
  function test_skipWhileAsync(t) {
    const async = t.startAsync('test_skipWhileAsync');

    const output = [],
      c = chain([fromIterable([1, 2, 3, 4, 5]), skipWhile(delay(x => x != 3)), streamToArray(output)]);

    c.on('end', () => {
      eval(t.TEST('t.unify(output, [3, 4, 5])'));
      async.done();
    });
  }
]);