@@ -153,8 +153,8 @@ export const submit = <A, I, R, SA, SE, SR>(
|
|||||||
): Effect.Effect<Option.Option<Result.Result<SA, SE>>, NoSuchElementException, Scope.Scope | SR> => Effect.whenEffect(
|
): Effect.Effect<Option.Option<Result.Result<SA, SE>>, NoSuchElementException, Scope.Scope | SR> => Effect.whenEffect(
|
||||||
self.valueRef.pipe(
|
self.valueRef.pipe(
|
||||||
Effect.andThen(identity),
|
Effect.andThen(identity),
|
||||||
Effect.andThen(value => Result.forkEffectScoped(
|
Effect.andThen(value => Result.forkEffectDequeue(
|
||||||
self.onSubmit(value) as Effect.Effect<SA, SE, Result.forkEffectScoped.InputContext<SR, never>>)
|
self.onSubmit(value) as Effect.Effect<SA, SE, Result.forkEffectDequeue.InputContext<SR, never>>)
|
||||||
),
|
),
|
||||||
Effect.andThen(Stream.fromQueue),
|
Effect.andThen(Stream.fromQueue),
|
||||||
Stream.unwrap,
|
Stream.unwrap,
|
||||||
|
|||||||
Reference in New Issue
Block a user