Here is my really hacky solution to the execution bounds problem:
import java.lang.reflect.Field
import akka.actor.ActorSystem
import akka.stream.testkit.{TestPublisher, TestSubscriber}
import akka.testkit.{TestKit, TestProbe}
import scala.concurrent.duration.FiniteDuration
/**
* Really hacky
Hi Jason,
I'm a newbie pursuing Streams testing as well.
I was wondering if you had run into; or found a way through a couple of the
build.sbt dependency issues I was running into with the v2.9 Docs on Akka
WebSocket support with Streams? (Pls see my recent posts!)
If so; would you mind