MCPcopy Index your code
hub / github.com/Effect-TS/effect / mergeAllUnboundedWith

Function mergeAllUnboundedWith

packages/effect/src/internal/channel.ts:1051–1083  ·  view source on GitHub ↗
(
  channels: Channel.Channel<
    Channel.Channel<OutElem, InElem1, OutErr1, InErr1, OutDone, InDone1, Env1>,
    InElem,
    OutErr,
    InErr,
    OutDone,
    InDone,
    Env
  >,
  f: (o1: OutDone, o2: OutDone) => OutDone
)

Source from the content-addressed store, hash-verified

1049
1050/** @internal */
1051export const mergeAllUnboundedWith = <
1052 OutElem,
1053 InElem1,
1054 OutErr1,
1055 InErr1,
1056 OutDone,
1057 InDone1,
1058 Env1,
1059 InElem,
1060 OutErr,
1061 InErr,
1062 InDone,
1063 Env
1064>(
1065 channels: Channel.Channel<
1066 Channel.Channel<OutElem, InElem1, OutErr1, InErr1, OutDone, InDone1, Env1>,
1067 InElem,
1068 OutErr,
1069 InErr,
1070 OutDone,
1071 InDone,
1072 Env
1073 >,
1074 f: (o1: OutDone, o2: OutDone) => OutDone
1075): Channel.Channel<
1076 OutElem,
1077 InElem & InElem1,
1078 OutErr | OutErr1,
1079 InErr & InErr1,
1080 OutDone,
1081 InDone & InDone1,
1082 Env | Env1
1083> => mergeAllWith({ concurrency: "unbounded" })(channels, f)
1084
1085/** @internal */
1086export const mergeAllWith = (

Callers

nothing calls this directly

Calls 1

mergeAllWithFunction · 0.85

Tested by

no test coverage detected