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

=stk accept Throwable in stream probe's sendError methods (#23940)

Browse source
This commit is contained in:
Johannes Rudolph 2017-11-09 09:12:58 +01:00 • committed by Johan Andrén
parent 4d583d1e6c
commit 9d7621150f
2 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
View file

@ -220,7 +220,7 @@ object TestPublisher {
this
}
def sendError(cause: Exception): Self = {
def sendError(cause: Throwable): Self = {
subscription.sendError(cause)
this
}
@ -795,7 +795,7 @@ private[testkit] object StreamTestKit {
def sendNext(element: I): Unit = subscriber.onNext(element)
def sendComplete(): Unit = subscriber.onComplete()
def sendError(cause: Exception): Unit = subscriber.onError(cause)
def sendError(cause: Throwable): Unit = subscriber.onError(cause)
def sendOnSubscribe(): Unit = subscriber.onSubscribe(this)
}

1
build.sbt
View file

@ -309,6 +309,7 @@ lazy val streamTestkit = akkaModule("akka-stream-testkit")
.dependsOn(stream, testkit % "compile->compile;test->test")
.settings(Dependencies.streamTestkit)
.settings(OSGi.streamTestkit)
.disablePlugins(MimaPlugin)
lazy val streamTests = akkaModule("akka-stream-tests")
.dependsOn(streamTestkit % "test->test", stream)