content

  object Fair {

    final case class Ports[T]() extends FlexiPorts[T](name = "Fair") {
      val input1 = createInputPort[T]()
      val input2 = createInputPort[T]()
    }

    final case class Logic[T]() extends FlexiMerge[T, Ports[T]](Ports()) {

      val readAny = State[T](ReadAny(ports.input1, ports.input2)) { (ctx, input, element) ⇒
        ctx.emit(element)
        SameState
      }

      override def initialState = readAny
    }
  }