Merge pull request #271 from kubukoz/fs2-observe

Replace redundant `observe` with `through`
vigoo · Jun 7, 2021 · f1fe040 · f1fe040
2 parents 70340bc + 529b0cf
commit f1fe040
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/prox-fs2-3/src/main/scala/io/github/vigoo/prox/ProxFS2.scala b/prox-fs2-3/src/main/scala/io/github/vigoo/prox/ProxFS2.scala
@@ -82,7 +82,7 @@ trait ProxFS2[F[_]] extends Prox {
 
   protected override final def drainToJavaOutputStream(stream: ProxStream[Byte], output: io.OutputStream, flushChunks: Boolean): ProxIO[Unit] =
     stream
-      .observe(
+      .through(
         if (flushChunks) writeAndFlushOutputStream(output)(_).drain
         else fs2.io.writeOutputStream(
           effect(output, UnknownProxError.apply),

diff --git a/prox-fs2/src/main/scala/io/github/vigoo/prox/ProxFS2.scala b/prox-fs2/src/main/scala/io/github/vigoo/prox/ProxFS2.scala
@@ -85,7 +85,7 @@ trait ProxFS2[F[_]] extends Prox {
 
   protected override final def drainToJavaOutputStream(stream: ProxStream[Byte], output: io.OutputStream, flushChunks: Boolean): ProxIO[Unit] =
     stream
-      .observe(
+      .through(
         if (flushChunks) writeAndFlushOutputStream(output)
         else fs2.io.writeOutputStream(
           effect(output, UnknownProxError.apply),