=str #17377: Turn off debug validation
This commit is contained in:
parent
9125a719fe
commit
605bbbce86
3 changed files with 2 additions and 7 deletions
|
|
@ -60,7 +60,7 @@ private[akka] case class ActorFlowMaterializerImpl(
|
|||
}
|
||||
|
||||
override def materialize[Mat](runnableFlow: Graph[ClosedShape, Mat]): Mat = {
|
||||
runnableFlow.module.validate()
|
||||
if (StreamLayout.Debug) runnableFlow.module.validate()
|
||||
|
||||
val session = new MaterializerSession(runnableFlow.module) {
|
||||
private val flowName = createFlowName()
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@ import akka.event.Logging.simpleName
|
|||
private[akka] object StreamLayout {
|
||||
|
||||
// compile-time constant
|
||||
final val Debug = true
|
||||
final val Debug = false
|
||||
|
||||
// TODO: Materialization order
|
||||
// TODO: Special case linear composites
|
||||
|
|
|
|||
|
|
@ -12,11 +12,6 @@ import scala.annotation.{ switch, tailrec }
|
|||
import scala.collection.breakOut
|
||||
import scala.util.control.NonFatal
|
||||
|
||||
// TODO:
|
||||
// fix jumpback table with keep-going-on-complete ops (we might jump between otherwise isolated execution regions)
|
||||
// implement grouped, buffer
|
||||
// add recover
|
||||
|
||||
/**
|
||||
* INTERNAL API
|
||||
*/
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue