Lorem Ipsum MCP Server

import { dual } from "../../Function.js" import type * as MergeStrategy from "../../MergeStrategy.js" import { hasProperty } from "../../Predicate.js" import * as OpCodes from "../opCodes/channelMergeStrategy.js" /** @internal */ const MergeStrategySymbolKey = "effect/ChannelMergeStrategy" /** @internal */ export const MergeStrategyTypeId: MergeStrategy.MergeStrategyTypeId = Symbol.for( MergeStrategySymbolKey ) as MergeStrategy.MergeStrategyTypeId /** @internal */ const proto = { [MergeStrategyTypeId]: MergeStrategyTypeId } /** @internal */ export const BackPressure = (_: void): MergeStrategy.MergeStrategy => { const op = Object.create(proto) op._tag = OpCodes.OP_BACK_PRESSURE return op } /** @internal */ export const BufferSliding = (_: void): MergeStrategy.MergeStrategy => { const op = Object.create(proto) op._tag = OpCodes.OP_BUFFER_SLIDING return op } /** @internal */ export const isMergeStrategy = (u: unknown): u is MergeStrategy.MergeStrategy => hasProperty(u, MergeStrategyTypeId) /** @internal */ export const isBackPressure = (self: MergeStrategy.MergeStrategy): self is MergeStrategy.BackPressure => self._tag === OpCodes.OP_BACK_PRESSURE /** @internal */ export const isBufferSliding = (self: MergeStrategy.MergeStrategy): self is MergeStrategy.BufferSliding => self._tag === OpCodes.OP_BUFFER_SLIDING /** @internal */ export const match = dual< <A>(options: { readonly onBackPressure: () => A readonly onBufferSliding: () => A }) => (self: MergeStrategy.MergeStrategy) => A, <A>( self: MergeStrategy.MergeStrategy, options: { readonly onBackPressure: () => A readonly onBufferSliding: () => A } ) => A >(2, <A>( self: MergeStrategy.MergeStrategy, { onBackPressure, onBufferSliding }: { readonly onBackPressure: () => A readonly onBufferSliding: () => A } ): A => { switch (self._tag) { case OpCodes.OP_BACK_PRESSURE: { return onBackPressure() } case OpCodes.OP_BUFFER_SLIDING: { return onBufferSliding() } } })