package io.reactors
package protocol



import scala.collection._
import scala.concurrent._
import scala.concurrent.duration._



class StreamingLibraryTest extends AsyncFunSuite with AsyncTimeLimitedTests {
  val system = ReactorSystem.default("streaming-lib")

  def timeLimit = 10.seconds

  implicit override def executionContext = ExecutionContext.Implicits.global

  test("streaming map") {
    // TODO: Implement test.
  }
}

Add streaming library test stub.
Add streaming library test stub.
