(
label: string,
n: number
)
| 157 | : Channel.succeed("end") |
| 158 | |
| 159 | const sum = ( |
| 160 | label: string, |
| 161 | n: number |
| 162 | ): Channel.Channel<never, number, unknown, unknown, void, unknown> => |
| 163 | Channel.readWith({ |
| 164 | onInput: (input: number) => sum(label, n + input), |
| 165 | onFailure: () => Channel.fromEffect(Ref.update(ref, (array) => [...array, n])), |
| 166 | onDone: () => Channel.fromEffect(Ref.update(ref, (array) => [...array, n])) |
| 167 | }) |
| 168 | |
| 169 | const channel = pipe( |
| 170 | intProducer, |
no test coverage detected