We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cc4d2c3 commit d739beeCopy full SHA for d739bee
packages/platform/test/HttpApp.test.ts
@@ -38,20 +38,22 @@ describe("Http/App", () => {
38
})
39
40
test("stream scope", async () => {
41
+ let order = 0
42
let streamFinalized = 0
43
let handlerFinalized = 0
44
const handler = HttpApp.toWebHandler(Effect.gen(function*() {
45
yield* Effect.addFinalizer(() =>
46
Effect.sync(() => {
- handlerFinalized = Date.now()
47
+ handlerFinalized = order
48
+ order += 1
49
50
)
51
const stream = Stream.make("foo", "bar").pipe(
52
Stream.encodeText,
53
Stream.ensuring(Effect.sync(() => {
- streamFinalized = Date.now()
- })),
54
- Stream.tap(() => Effect.sleep(50))
+ streamFinalized = order
55
56
+ }))
57
58
return HttpServerResponse.stream(stream)
59
}))
0 commit comments