public _start(out: Stream<Array<T>>): void {
    this.out = out;
    this.ins._add(this);
  }