Added {Readable,Subscribable}.unwrap (#2498)

Effect-TS · Apr 9, 2024 · e983740 · e983740
1 parent 4c37001
commit e983740
Show file tree

Hide file tree

Showing 3 changed files with 28 additions and 0 deletions.
diff --git a/.changeset/wild-lamps-promise.md b/.changeset/wild-lamps-promise.md
@@ -0,0 +1,5 @@
+---
+"effect": patch
+---
+
+added {Readable, Subscribable}.unwrap
diff --git a/packages/effect/src/Readable.ts b/packages/effect/src/Readable.ts
@@ -79,3 +79,14 @@ export const mapEffect: {
   self: Readable<A, E, R>,
   f: (a: NoInfer<A>) => Effect<B, E2, R2>
 ): Readable<B, E | E2, R | R2> => make(core.flatMap(self.get, f)))
+
+/**
+ * @since 2.0.0
+ * @category constructors
+ */
+export const unwrap = <A, E, R, E1, R1>(
+  effect: Effect<Readable<A, E, R>, E1, R1>
+): Readable<A, E | E1, R | R1> =>
+  make(
+    core.flatMap(effect, (s) => s.get)
+  )
diff --git a/packages/effect/src/Subscribable.ts b/packages/effect/src/Subscribable.ts
@@ -85,3 +85,15 @@ export const mapEffect: {
     get: Effect.flatMap(self.get, f),
     changes: Stream.mapEffect(self.changes, f)
   }))
+
+/**
+ * @since 2.0.0
+ * @category constructors
+ */
+export const unwrap = <A, E, R, E1, R1>(
+  effect: Effect.Effect<Subscribable<A, E, R>, E1, R1>
+): Subscribable<A, E | E1, R | R1> =>
+  make({
+    get: Effect.flatMap(effect, (s) => s.get),
+    changes: Stream.unwrap(Effect.map(effect, (s) => s.changes))
+  })