Merge pull request #3467 from mpilquist/topic/digest

Refactor hashPureStream
typelevel · Aug 26, 2024 · ff9b4d1 · ff9b4d1
2 parents f8e2a33 + f093905
commit ff9b4d1
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/core/shared/src/main/scala/fs2/hashing/Hashing.scala b/core/shared/src/main/scala/fs2/hashing/Hashing.scala
@@ -97,10 +97,7 @@ object Hashing {
 
   /** Returns the hash of the supplied stream. */
   def hashPureStream(algorithm: HashAlgorithm, source: Stream[Pure, Byte]): Hash =
-    Hashing[SyncIO]
-      .hasher(algorithm)
-      .use(h => h.drain(source).compile.lastOrError)
-      .unsafeRunSync()
+    source.through(Hashing[SyncIO].hash(algorithm)).compile.lastOrError.unsafeRunSync()
 
   /** Returns the hash of the supplied chunk. */
   def hashChunk(algorithm: HashAlgorithm, chunk: Chunk[Byte]): Hash =