diff --git a/core/src/test/scala/org/http4s/blaze/pipeline/stages/SSLStageSuite.scala b/core/src/test/scala/org/http4s/blaze/pipeline/stages/SSLStageSuite.scala index 732be0dc8..8516ec163 100644 --- a/core/src/test/scala/org/http4s/blaze/pipeline/stages/SSLStageSuite.scala +++ b/core/src/test/scala/org/http4s/blaze/pipeline/stages/SSLStageSuite.scala @@ -63,7 +63,7 @@ class SSLStageSuite extends BlazeTestSuite { test(testSuitePrefix + " should split large buffers") { val (headEng, stageEng) = mkClientServerEngines - val s = "Fo" * (stageEng.getSession.getPacketBufferSize * 0.75).toInt + val s = "Fo" * (stageEng.getSession.getPacketBufferSize * 0.45).toInt /* The detection of splitting the buffer is seen by checking the write * output: if its flushing, the output should only be single buffers for @@ -87,14 +87,16 @@ class SSLStageSuite extends BlazeTestSuite { head.sendInboundCommand(Connected) - assertFuture_(tail.startLoop()).flatMap(_ => - assertFuture( + for { + _ <- tail.startLoop() + _ <- assertFuture( for { r <- Future(BufferTools.mkString(head.results)) h <- Future(head.multipleWrite) } yield r -> h, s + s -> false - )) + ) + } yield () } test(testSuitePrefix + " should transcode multiple single byte buffers") {