Could it be possible to provide more details on how a resulting error defined on the the error channel for EventApplier would be handled in endless(akka/pekko) internally?
Thanks!
trait EventApplier[S, E] extends ((Option[S], E) => String \/ Option[S])