resonate.message_sources.LocalMessageSource

class documentation

class LocalMessageSource:

Constructor: LocalMessageSource(store, group, id, scheme)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method enqueue Undocumented
Method match Undocumented
Method next Undocumented
Method start Undocumented
Method stop Undocumented
Property anycast Undocumented
Property group Undocumented
Property id Undocumented
Property unicast Undocumented
Instance Variable _group Undocumented
Instance Variable _id Undocumented
Instance Variable _messages Undocumented
Instance Variable _scheme Undocumented
Instance Variable _store Undocumented
def __init__(self, store: LocalStore, group: str, id: str, scheme: str = 'local'):

Undocumented

def enqueue(self, mesg: Mesg):

Undocumented

def match(self, addr: str) -> tuple[bool, bool]:

Undocumented

def next(self) -> Mesg | None:

Undocumented

def start(self):

Undocumented

def stop(self):

Undocumented

@property
anycast: str =

Undocumented

@property
group: str =

Undocumented

@property
id: str =

Undocumented

@property
unicast: str =

Undocumented

_group =

Undocumented

_id =

Undocumented

_messages =

Undocumented

_scheme =

Undocumented

_store =

Undocumented