Type Members

1.  class CloseExecutionException extends Exception
2.  final case class CommMessageHandlers(commManager: CommTargetManager, queueEc: ExecutionContext, logCtx: LoggerContext) extends Product with Serializable
3.  final case class InterpreterMessageHandlers(interpreter: IOInterpreter, commHandlerOpt: Option[CommHandler], inputHandlerOpt: Option[InputHandler], queueEc: ExecutionContext, logCtx: LoggerContext, runAfterQueued: (IO[Unit]) => IO[Unit], exitSignal: SignallingRef[IO, Boolean], noExecuteInputFor: Set[String]) extends Product with Serializable
4.  final case class MessageHandler(handler: PartialFunction[(Channel, Message[RawJson]), Either[Throwable, Stream[IO, (Channel, channels.Message)]]]) extends Product with Serializable

   Wraps a partial function, able to handle some Messages arriving via a given Channel.

   Wraps a partial function, able to handle some Messages arriving via a given Channel.

   If a Message is handled, one can get either a Throwable, meaning the message was malformed, or a Stream of RawMessage to be sent on a given Channel as answer.