(request: () => Promise<{ response: Response }>, status: number)
| 133 | } |
| 134 | |
| 135 | function expectStatus(request: () => Promise<{ response: Response }>, status: number) { |
| 136 | return call(request).pipe( |
| 137 | Effect.tap((result) => Effect.sync(() => expect(result.response.status).toBe(status))), |
| 138 | Effect.asVoid, |
| 139 | ) |
| 140 | } |
| 141 | |
| 142 | function firstEvent(open: (signal: AbortSignal) => Promise<{ stream: AsyncIterator<unknown> }>) { |
| 143 | return Effect.acquireRelease( |
no test coverage detected