Tyrian
API
Generated with
Tyrian/tyrian/tyrian.runtime/SubHelper

SubHelper

tyrian.runtime.SubHelper
object SubHelper

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type
SubHelper.type

Members list

Value members

Concrete methods

def aliveAndDead[F[_] : Concurrent, Msg](subs: List[Observe[F, _, Msg]], current: List[(String, F[Unit])]): (List[(String, F[Unit])], List[F[Unit]])
def findNewSubs[F[_] : Concurrent, Msg](subs: List[Observe[F, _, Msg]], alive: List[String], inProgress: List[String]): List[Observe[F, _, Msg]]
def flatten[F[_], Msg](sub: Sub[F, Msg]): List[Observe[F, _, Msg]]
def runObserve[F[_], A, Msg](sub: Observe[F, A, Msg])(callback: Either[Throwable, Option[Msg]] => Unit)(using F: Concurrent[F]): F[(String, F[Unit])]
Generated with