Translate TestCanceled to fireAssumptionFailed

[retronym]

No description provided.

[cla-bot]

Hi @retronym, we require contributors to sign our Contributor License Agreement, and we don't have yours on file. In order for us to review and merge your code, please access https://www.artima.com/cla/choose-type to sign our Contributor License Agreement. Your effort is highly appreciated. Thank you.

[cla-bot]

Hi @retronym, we require contributors to sign our Contributor License Agreement, and we don't have yours on file. In order for us to review and merge your code, please access https://www.artima.com/cla/choose-type to sign our Contributor License Agreement. Your effort is highly appreciated. Thank you.

[artimasites]

@cla-bot[bot] check

[cla-bot]

The cla-bot has been summoned, and re-checked this pull request!

[cheeseng]

@retronym Thanks for the PR! The changes looks good! I'll port this over to scalatest+junit5 as well.

[lrytz]

Bump 🛎️

[tech-jun-jones]

retronym:feature/assumption-failure

[tech-jun-jones]

class IterablePublisherTest(env: TestEnvironment, publisherShutdownTimeout: Long)
extends PublisherVerification[Int](env, publisherShutdownTimeout)
with TestNGSuiteLike {

def this() {
this(new TestEnvironment(500), 1000)
}

def createPublisher(elements: Long): Publisher[Int] = ???

// example error state publisher implementation
override def createFailedPublisher(): Publisher[Int] =
new Publisher[Int] {
override def subscribe(s: Subscriber[Int]): Unit =
s.onError(new Exception("Unable to serve subscribers right now!"))
}

}