| 137 | |
| 138 | describe("destructors", () => { |
| 139 | const withScopeFinalizer = <A, E, R>( |
| 140 | self: Stream.Stream<A, E, R>, |
| 141 | finalizer: (exit: Exit.Exit<unknown, unknown>) => Effect.Effect<unknown> |
| 142 | ): Stream.Stream<A, E, R> => |
| 143 | Stream.fromChannel( |
| 144 | Channel.fromTransform((upstream, scope) => |
| 145 | Effect.andThen( |
| 146 | Scope.addFinalizerExit(scope, finalizer), |
| 147 | Channel.toTransform(Stream.toChannel(self))(upstream, scope) |
| 148 | ) |
| 149 | ) |
| 150 | ) |
| 151 | |
| 152 | it.effect("mkArrayBuffer - concatenates Uint8Array chunks", () => |
| 153 | Effect.gen(function*() { |