raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

#19553 One2OneBidi should report truncation also if wrapped flow cancels early

Browse source
This commit is contained in:
Endre Sándor Varga 2016-02-04 12:40:29 +01:00
parent 0170280fc0
commit 8e37ff42f5
4 changed files with 21 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-http-core/src/test/scala/akka/http/impl/engine/client/HighLevelOutgoingConnectionSpec.scala
View file

@ -6,7 +6,7 @@ package akka.http.impl.engine.client
import scala.concurrent.Await
import scala.concurrent.duration._
import akka.stream.{ FlowShape, ActorMaterializer }
import akka.stream.{ ActorMaterializerSettings, FlowShape, ActorMaterializer }
import akka.stream.scaladsl._
import akka.stream.testkit.AkkaSpec
import akka.http.scaladsl.{ Http, TestUtils }
@ -15,7 +15,7 @@ import akka.stream.testkit.Utils
import org.scalatest.concurrent.ScalaFutures
class HighLevelOutgoingConnectionSpec extends AkkaSpec with ScalaFutures {
implicit val materializer = ActorMaterializer()
implicit val materializer = ActorMaterializer(ActorMaterializerSettings(system).withFuzzing(true))
implicit val patience = PatienceConfig(1.second)
"The connection-level client implementation" should {

2
akka-http-core/src/test/scala/akka/http/impl/engine/client/LowLevelOutgoingConnectionSpec.scala
View file

@ -288,7 +288,7 @@ class LowLevelOutgoingConnectionSpec extends AkkaSpec("akka.loggers = []\n akka.
val error @ EntityStreamException(info) = probe.expectError()
info.summary shouldEqual "Illegal chunk termination"
responses.expectComplete()
responses.expectError()
netOut.expectComplete()
requestsSub.expectCancellation()
netInSub.expectCancellation()