akka_streams_pitfalls_9_1.scala

val nonLinearFlow = Flow.fromGraph(GraphDSL.create() { implicit builder =>
  
 import GraphDSL.Implicits._
  
 val dangerousFlow = Flow[Int].map {
   case 5 => throw new RuntimeException(“BOOM!”)
   case x => x
 }
  
 val safeFlow = Flow[Int]
  
 val bcast = builder.add(Broadcast[Int](2))
 val zip = builder.add(Zip[Int, Int])
  
 bcast ~> dangerousFlow ~> zip.in0
 bcast ~> safeFlow ~> zip.in1
  
 FlowShape(bcast.in, zip.out)
})