From fee3dc30f1e3bc852f51c302c0206b39868db336 Mon Sep 17 00:00:00 2001 From: Rob Norris Date: Fri, 14 Aug 2020 14:31:39 -0500 Subject: [PATCH] oops --- io/src/main/scala/fs2/io/tls/TLSSocket.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/io/src/main/scala/fs2/io/tls/TLSSocket.scala b/io/src/main/scala/fs2/io/tls/TLSSocket.scala index 8ba8188efe..18f55d3132 100644 --- a/io/src/main/scala/fs2/io/tls/TLSSocket.scala +++ b/io/src/main/scala/fs2/io/tls/TLSSocket.scala @@ -58,7 +58,7 @@ object TLSSocket { val toRead = numBytes - acc.size if (toRead <= 0) Applicative[F].pure(Some(acc.toChunk)) else - read0(numBytes, timeout).flatMap { + read0(toRead, timeout).flatMap { case Some(chunk) => go(acc :+ chunk): F[Option[Chunk[Byte]]] case None => Applicative[F].pure(Some(acc.toChunk)): F[Option[Chunk[Byte]]] }