/** * @tsplus type effect/core/stream/Channel/UpstreamPullRequest */ export type UpstreamPullRequest = Pulled | NoUpstream; export declare class Pulled { readonly value: A; readonly _tag = "Pulled"; constructor(value: A); } export declare class NoUpstream { readonly activeDownstreamCount: number; readonly _tag = "NoUpstream"; constructor(activeDownstreamCount: number); } /** * @tsplus type effect/core/stream/Channel/UpstreamPullRequest.Ops */ export interface UpstreamPullRequestOps { } export declare const UpstreamPullRequest: UpstreamPullRequestOps; /** * @tsplus unify effect/core/stream/Channel/UpstreamPullRequest */ export declare function unifyUpstreamPullRequest>(self: X): UpstreamPullRequest<[X] extends [UpstreamPullRequest] ? AX : never>; /** * @tsplus static effect/core/stream/Channel/UpstreamPullRequest.Ops Pulled * @tsplus location "@effect/core/stream/Channel/UpstreamPullRequest" */ export declare function pulled(value: A): UpstreamPullRequest; /** * @tsplus static effect/core/stream/Channel/UpstreamPullRequest.Ops NoUpstream * @tsplus location "@effect/core/stream/Channel/UpstreamPullRequest" */ export declare function noUpstream(activeDownstreamCount: number): UpstreamPullRequest; //# sourceMappingURL=UpstreamPullRequest.d.ts.map