import type * as Arr from "../Array.ts"
import type * as Channel from "../Channel.ts"
import { identity } from "../Function.ts"
import { pipeArguments } from "../Pipeable.ts"
import type { Stream } from "../Stream.ts"

const TypeId = "~effect/Stream"

const streamVariance = {
  _R: identity,
  _E: identity,
  _A: identity
}

const Stream: {
  new<A extends Arr.NonEmptyReadonlyArray<any>, E, R>(
    channel: Channel.Channel<A, E, void, unknown, unknown, unknown, R>
  ): Stream<A extends Arr.NonEmptyReadonlyArray<infer A> ? A : never, E, R>
} = function<A extends Arr.NonEmptyReadonlyArray<any>, E, R>(
  this: any,
  channel: Channel.Channel<A, E, void, unknown, unknown, unknown, R>
) {
  this.channel = channel
} as any

Stream.prototype = {
  [TypeId]: streamVariance,
  pipe() {
    return pipeArguments(this, arguments)
  }
}

/** @internal */
export const fromChannel = <A extends Arr.NonEmptyReadonlyArray<any>, E, R>(
  channel: Channel.Channel<A, E, void, unknown, unknown, unknown, R>
): Stream<A extends Arr.NonEmptyReadonlyArray<infer A> ? A : never, E, R> => new Stream(channel)