()
| 106 | Channel.fromEffect(Ref.make<ReadonlyArray<number>>([])), |
| 107 | Channel.flatMap((ref) => { |
| 108 | const inner = (): Channel.Channel<number, number, never, unknown, void, unknown> => |
| 109 | Channel.readWith({ |
| 110 | onInput: (input: number) => |
| 111 | pipe( |
| 112 | Channel.fromEffect(Ref.update(ref, (array) => [...array, input])), |
| 113 | Channel.zipRight(Channel.write(input)), |
| 114 | Channel.flatMap(inner) |
| 115 | ), |
| 116 | onFailure: () => Channel.void, |
| 117 | onDone: () => Channel.void |
| 118 | }) |
| 119 | return pipe( |
| 120 | inner(), |
| 121 | Channel.zipRight(Channel.fromEffect(Ref.get(ref))) |
no test coverage detected
searching dependent graphs…