adamw · June 10, 2018 18:20
diff --git a/BroadcastBehavior.scala b/BroadcastBehavior.scala
 def handleMessage(consumers: Set[ActorRef[String]]): Behavior[BroadcastActorMessage] = 
  Behaviors.receiveMessage {
    case Subscribe(actor) => handleMessage(consumers + actor)
    case Received(msg) =>
      consumers.foreach(_ ! msg)
      handleMessage(consumers)
  }
	def handleMessage(consumers: Set[ActorRef[String]]): Behavior[BroadcastActorMessage] =
	Behaviors.receiveMessage {
	case Subscribe(actor) => handleMessage(consumers + actor)
	case Received(msg) =>
	consumers.foreach(_ ! msg)
	handleMessage(consumers)
	}