@@ -265,6 +265,7 @@ export const fromSynchronizedRef = <A>(
|
|||||||
ref: SynchronizedRef.SynchronizedRef<A>
|
ref: SynchronizedRef.SynchronizedRef<A>
|
||||||
): Lens<A, never, never, never, never> => new SynchronizedRefLensImpl(ref)
|
): Lens<A, never, never, never, never> => new SynchronizedRefLensImpl(ref)
|
||||||
|
|
||||||
|
|
||||||
export class SubscriptionRefLensImpl<in out A>
|
export class SubscriptionRefLensImpl<in out A>
|
||||||
extends LensImpl<A, never, never, never, never> {
|
extends LensImpl<A, never, never, never, never> {
|
||||||
constructor(
|
constructor(
|
||||||
@@ -667,12 +668,12 @@ export const tapError: {
|
|||||||
value: resolved.value,
|
value: resolved.value,
|
||||||
commit: next => Effect.flatMap(
|
commit: next => Effect.flatMap(
|
||||||
next,
|
next,
|
||||||
value => Effect.tapError(resolved.commit(Effect.succeed(value)), (error: EW) => f(error)),
|
value => Effect.tapError(resolved.commit(Effect.succeed(value)), e => f(e)),
|
||||||
),
|
),
|
||||||
}),
|
}),
|
||||||
),
|
),
|
||||||
mapStream: Stream.tapError((error: ER) => f(error)),
|
mapStream: Stream.tapError(e => f(e)),
|
||||||
mapLock: Effect.tapError((error: EW) => f(error)),
|
mapLock: Effect.tapError(e => f(e)),
|
||||||
}))
|
}))
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user