StreamingSpec converted to scalatest