@@ -267,7 +267,7 @@ export class Reffuse<R> {
|
|||||||
|
|
||||||
return () => {
|
return () => {
|
||||||
Fiber.interrupt(fiber).pipe(
|
Fiber.interrupt(fiber).pipe(
|
||||||
Effect.flatMap(() => Scope.close(scope, Exit.void)),
|
Effect.andThen(Scope.close(scope, Exit.void)),
|
||||||
runFork,
|
runFork,
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user