(expected: string, seen = "")
| 157 | const write = yield* socket.writer |
| 158 | |
| 159 | const takeUntil = (expected: string, seen = ""): Effect.Effect<string, unknown> => |
| 160 | Effect.gen(function* () { |
| 161 | const next = seen + (yield* Queue.take(messages).pipe(Effect.timeout("5 seconds"))) |
| 162 | if (next.includes(expected)) return next |
| 163 | return yield* takeUntil(expected, next) |
| 164 | }) |
| 165 | |
| 166 | yield* write("ping-v2\n") |
| 167 | expect(yield* takeUntil("ping-v2")).toContain("ping-v2") |
no outgoing calls
no test coverage detected