Julien Valverdé
33 lines
1.1 KiB
TypeScript
33 lines
1.1 KiB
TypeScript
import { Effect, Effectable, Readable, Stream, Subscribable, type SubscriptionRef } from "effect"
|
|
|
|
|
|
class SubscribableImpl<A, E, R>
|
|
extends Effectable.Class<A, E, R> implements Subscribable.Subscribable<A, E, R> {
|
|
readonly [Readable.TypeId]: Readable.TypeId = Readable.TypeId
|
|
readonly [Subscribable.TypeId]: Subscribable.TypeId = Subscribable.TypeId
|
|
|
|
constructor(
|
|
readonly get: Effect.Effect<A, E, R>,
|
|
readonly changes: Stream.Stream<A, E, R>,
|
|
) {
|
|
super()
|
|
}
|
|
|
|
commit() {
|
|
return this.get
|
|
}
|
|
}
|
|
|
|
export const make = <A, E, R>(values: {
|
|
readonly get: Effect.Effect<A, E, R>
|
|
readonly changes: Stream.Stream<A, E, R>
|
|
}): Subscribable.Subscribable<A, E, R> => new SubscribableImpl(values.get, values.changes)
|
|
|
|
export const flatMapSubscriptionRef = <A, B, E, R>(
|
|
ref: SubscriptionRef.SubscriptionRef<A>,
|
|
flatMap: (value: NoInfer<A>) => Effect.Effect<B, E, R>,
|
|
): Subscribable.Subscribable<B, E, R> => make({
|
|
get: Effect.flatMap(ref, flatMap),
|
|
get changes() { return Stream.flatMap(ref.changes, flatMap) },
|
|
})
|