/**
 * @license Use of this source code is governed by an MIT-style license that
 * can be found in the LICENSE file at https://github.com/cartant/rxjs-etc
 */
/*tslint:disable:no-unused-expression*/

import { marbles } from "rxjs-marbles";
import { concatArray } from "./concatArray";

// prettier-ignore
describe("concatArray", () => {
  it(
    "should concat a single observable",
    marbles(m => {
      const source = m.cold("   a----|");
      const subs = "            ^----!";
      const expected = m.cold(" a----|");

      const destination = concatArray([source]);
      m.expect(destination).toBeObservable(expected);
      m.expect(source).toHaveSubscriptions(subs);
    })
  );

  it(
    "should concat multiple observables",
    marbles(m => {
      const source1 = m.cold("  a--|");
      const subs1 = "           ^--!";
      const source2 = m.cold("  b----|");
      const subs2 = "           ---^----!";
      const expected = m.cold(" a--b----|");

      const destination = concatArray([source1, source2]);
      m.expect(destination).toBeObservable(expected);
      m.expect(source1).toHaveSubscriptions(subs1);
      m.expect(source2).toHaveSubscriptions(subs2);
    })
  );

  it(
    "should complete when observables is empty",
    marbles(m => {
      const expected = m.cold("|");
      const destination = concatArray([]);
      m.expect(destination).toBeObservable(expected);
    })
  );
});