const {hi, pi, Subject} = require('hipi');

    const fn1 = hi(async (value, next) => next(value));
    expect(await fn1('any-input')).equal('any-input');

    const addFive = pi(
      hi(async (value, next) => next(value + 1)),
      hi((value, next) => next(value + 1)),
      hi((value, next) => next(value + 3))
    );
 
    expect(await addFive(0)).equal(5);

    const addFive = pi(
      value => value,
      value => value + 1,
      value => value + 4
    );
 
    expect(await addFive(0)).equal(5);

    let counterIn = 0;
    let counterOut = 0;
 
    const outputs = [];
 
    const addValues3Times = pi(
      hi(async (value, next) => {
        counterIn += 1;
        await next(value + 133);
        await next(value + 120);
        await next(value + 1);
      }),
      hi(async (value, next) => next(value)),
      hi(async (value, next) => {
        outputs.push(value);
 
        counterOut += 1;
        await next(value);
      })
    );
 
    expect(await addValues3Times(1)).equal(2);
 
    expect(counterIn).equal(1);
    expect(counterOut).equal(3);
 
    expect(outputs).deep.equal([134, 121, 2]);

    const subject = Subject();
    const output = [];
 
    subject.subscribe(value => output.push(value));
 
    expect(output).deep.equal([]);
 
    await subject(123);
    await subject(456);
 
    expect(output).deep.equal([123, 456]);

    const hi1 = hi(async (value, next) => next(value));
    const subject = Subject(hi1);
 
    let expected = null;
    const unsubscribe = subject.subscribe(value => expected = value);
 
    await hi1('okk1');
 
    unsubscribe()
    expect(expected).equal('okk1');