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;