0.2.5 #43
@@ -223,9 +223,7 @@ export const unsafeForkEffect = Effect.fnUntraced(function* <A, E, R, P = never>
|
|||||||
([latest, stream]) => Stream.concat(Stream.make(latest), stream),
|
([latest, stream]) => Stream.concat(Stream.make(latest), stream),
|
||||||
))
|
))
|
||||||
},
|
},
|
||||||
modify: <B, E1, R1>(
|
modify: f => Ref.get(ref).pipe(
|
||||||
f: (a: Result<A, E, P>) => Effect.Effect<readonly [B, Result<A, E, P>], E1, R1>
|
|
||||||
): Effect.Effect<B, E1, R1> => Ref.get(ref).pipe(
|
|
||||||
Effect.flatMap(f),
|
Effect.flatMap(f),
|
||||||
Effect.flatMap(([b, a]) => Ref.set(ref, a).pipe(
|
Effect.flatMap(([b, a]) => Ref.set(ref, a).pipe(
|
||||||
Effect.as(b),
|
Effect.as(b),
|
||||||
|
|||||||
Reference in New Issue
Block a user