refactor(Stream/merge): rename arg names for clarity

Effect-TS · Jul 4, 2024 · 05b6480 · 05b6480
1 parent dbe532e
commit 05b6480
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 18 deletions.
diff --git a/.changeset/stream-merge-left-right.md b/.changeset/stream-merge-left-right.md
@@ -0,0 +1,7 @@
+---
+"effect": minor
+---
+
+refactor(Stream/mergeLeft): rename `self`/`that` argument names to `left`/`right` for clarity
+
+refactor(Stream/mergeRight): rename `self`/`that` argument names to `left`/`right` for clarity
diff --git a/packages/effect/src/Stream.ts b/packages/effect/src/Stream.ts
@@ -2232,8 +2232,8 @@ export const mergeEither: {
  * @category utils
  */
 export const mergeLeft: {
-  <A2, E2, R2>(that: Stream<A2, E2, R2>): <A, E, R>(self: Stream<A, E, R>) => Stream<A, E2 | E, R2 | R>
-  <A, E, R, A2, E2, R2>(self: Stream<A, E, R>, that: Stream<A2, E2, R2>): Stream<A, E | E2, R | R2>
+  <A2, E2, R2>(right: Stream<A2, E2, R2>): <A, E, R>(left: Stream<A, E, R>) => Stream<A, E2 | E, R2 | R>
+  <A, E, R, A2, E2, R2>(left: Stream<A, E, R>, right: Stream<A2, E2, R2>): Stream<A, E | E2, R | R2>
 } = internal.mergeLeft
 
 /**
@@ -2244,8 +2244,8 @@ export const mergeLeft: {
  * @category utils
  */
 export const mergeRight: {
-  <A2, E2, R2>(that: Stream<A2, E2, R2>): <A, E, R>(self: Stream<A, E, R>) => Stream<A2, E2 | E, R2 | R>
-  <A, E, R, A2, E2, R2>(self: Stream<A, E, R>, that: Stream<A2, E2, R2>): Stream<A2, E | E2, R | R2>
+  <A2, E2, R2>(right: Stream<A2, E2, R2>): <A, E, R>(left: Stream<A, E, R>) => Stream<A2, E2 | E, R2 | R>
+  <A, E, R, A2, E2, R2>(left: Stream<A, E, R>, right: Stream<A2, E2, R2>): Stream<A2, E | E2, R | R2>
 } = internal.mergeRight
 
 /**

diff --git a/packages/effect/src/internal/stream.ts b/packages/effect/src/internal/stream.ts
@@ -3922,35 +3922,35 @@ export const mergeEither = dual<
 /** @internal */
 export const mergeLeft = dual<
   <A2, E2, R2>(
-    that: Stream.Stream<A2, E2, R2>
-  ) => <A, E, R>(self: Stream.Stream<A, E, R>) => Stream.Stream<A, E2 | E, R2 | R>,
+    right: Stream.Stream<A2, E2, R2>
+  ) => <A, E, R>(left: Stream.Stream<A, E, R>) => Stream.Stream<A, E2 | E, R2 | R>,
   <A, E, R, A2, E2, R2>(
-    self: Stream.Stream<A, E, R>,
-    that: Stream.Stream<A2, E2, R2>
+    left: Stream.Stream<A, E, R>,
+    right: Stream.Stream<A2, E2, R2>
   ) => Stream.Stream<A, E2 | E, R2 | R>
 >(
   2,
   <A, E, R, A2, E2, R2>(
-    self: Stream.Stream<A, E, R>,
-    that: Stream.Stream<A2, E2, R2>
-  ): Stream.Stream<A, E | E2, R | R2> => pipe(self, merge(drain(that)))
+    left: Stream.Stream<A, E, R>,
+    right: Stream.Stream<A2, E2, R2>
+  ): Stream.Stream<A, E | E2, R | R2> => pipe(left, merge(drain(right)))
 )
 
 /** @internal */
 export const mergeRight = dual<
   <A2, E2, R2>(
-    that: Stream.Stream<A2, E2, R2>
-  ) => <A, E, R>(self: Stream.Stream<A, E, R>) => Stream.Stream<A2, E2 | E, R2 | R>,
+    right: Stream.Stream<A2, E2, R2>
+  ) => <A, E, R>(left: Stream.Stream<A, E, R>) => Stream.Stream<A2, E2 | E, R2 | R>,
   <A, E, R, A2, E2, R2>(
-    self: Stream.Stream<A, E, R>,
-    that: Stream.Stream<A2, E2, R2>
+    left: Stream.Stream<A, E, R>,
+    right: Stream.Stream<A2, E2, R2>
   ) => Stream.Stream<A2, E2 | E, R2 | R>
 >(
   2,
   <A, E, R, A2, E2, R2>(
-    self: Stream.Stream<A, E, R>,
-    that: Stream.Stream<A2, E2, R2>
-  ): Stream.Stream<A2, E | E2, R | R2> => pipe(drain(self), merge(that))
+    left: Stream.Stream<A, E, R>,
+    right: Stream.Stream<A2, E2, R2>
+  ): Stream.Stream<A2, E | E2, R | R2> => pipe(drain(left), merge(right))
 )
 
 /** @internal */