UpstreamPullStrategy

declare const PullAfterAllEnqueued: <A>(emitSeparator: Option<A>) => UpstreamPullStrategy<A>

declare const PullAfterNext: <A>(emitSeparator: Option<A>) => UpstreamPullStrategy<A>

declare const match: {
  <A, Z>(options: {
    readonly onAllEnqueued: (emitSeparator: Option.Option<A>) => Z;
    readonly onNext: (emitSeparator: Option.Option<A>) => Z;
  }): (self: UpstreamPullStrategy<A>) => Z;
  <A, Z>(self: UpstreamPullStrategy<A>, options: {
    readonly onAllEnqueued: (emitSeparator: Option.Option<A>) => Z;
    readonly onNext: (emitSeparator: Option.Option<A>) => Z;
  }): Z;
}

interface PullAfterAllEnqueued<out A> extends Variance<A> {
  readonly _tag: "PullAfterAllEnqueued";
  readonly emitSeparator: Option<A>;
}

interface PullAfterNext<out A> extends Variance<A> {
  readonly _tag: "PullAfterNext";
  readonly emitSeparator: Option<A>;
}

type UpstreamPullStrategy<A> = PullAfterNext<A> | PullAfterAllEnqueued<A>

declare const isPullAfterAllEnqueued: <A>(self: UpstreamPullStrategy<A>) => self is PullAfterAllEnqueued<A>

declare const isPullAfterNext: <A>(self: UpstreamPullStrategy<A>) => self is PullAfterNext<A>

declare const isUpstreamPullStrategy: (u: unknown) => u is UpstreamPullStrategy<unknown>

declare const UpstreamPullStrategyTypeId: unique symbol

type UpstreamPullStrategyTypeId = typeof UpstreamPullStrategyTypeId