Index

_

__call__() (IBackplaneFactory method) (IContainerFactory method) (ICoroutineFactory method) (IMessageFactory method) (IPostOfficeFactory method) (ISchedulerFactory method) _main() (Component method)

_message (M4USException attribute)

A

Adapter Adapters

AlreadyRegisteredError

B

Backplane backplane() (in module m4us.backplanes)

Backplanes

C

Callable Callables close() (Component method) (ICoroutine method) (ThreadedCoroutine method) Component (class in m4us.core.components) Components Concurrent Consumer

Consumers Container Coroutine coroutine() (in module m4us.core.coroutines) Coroutines coroutines (IContainer attribute) cycle() (IScheduler method) (Scheduler method)

D

DuplicateError

E

easy_link() (in module m4us.core.utils)

F

Factory Filter filter_() (in module m4us.core.coroutines)

filter_from_callable() (in module m4us.core.coroutines) Filters Framework

G

Generator Generators

Graphline (class in m4us.core.containers)

I

IBackplane (interface in m4us.interfaces) IBackplaneFactory (interface in m4us.interfaces) IContainer (interface in m4us.core.interfaces) IContainerFactory (interface in m4us.core.interfaces) ICoroutine (interface in m4us.core.interfaces) ICoroutineFactory (interface in m4us.core.interfaces) Idempotent IMessage (interface in m4us.core.interfaces) IMessageFactory (interface in m4us.core.interfaces) Inbox Inboxes init() (in module m4us.core.coroutines) INotLazy (interface in m4us.core.interfaces)

Interface interfaces InvalidLinkError IPostOffice (interface in m4us.core.interfaces) IPostOfficeFactory (interface in m4us.core.interfaces) IProducerFinished (interface in m4us.core.interfaces) IRegisterPublisher (interface in m4us.interfaces) is_shutdown() (in module m4us.core.utils) IScheduler (interface in m4us.core.interfaces) ISchedulerFactory (interface in m4us.core.interfaces) IShutdown (interface in m4us.core.interfaces) IThreadedCoroutine (interface in m4us.interfaces) IUnregisterPublisher (interface in m4us.interfaces)

L

Lazy Library Link

LinkExistsError Links links (IContainer attribute)

M

m4us (module) m4us.api (module) m4us.backplanes (module) m4us.concurrency (module) m4us.core (module) m4us.core.api (module) m4us.core.components (module) m4us.core.containers (module) m4us.core.coroutines (module) m4us.core.exceptions (module) m4us.core.interfaces (module)

m4us.core.messages (module) m4us.core.postoffices (module) m4us.core.schedulers (module) m4us.core.utils (module) m4us.interfaces (module) m4us.tests (module) M4USException Mailbox Mailboxes Message (class in m4us.core.messages) Messages

N

NeverRunError NoLinkError NotAddedError

NotASinkError NotRegisteredError null_sink() (in module m4us.core.coroutines)

O

Outbox

Outboxes

P

Pipeline (class in m4us.core.containers) Pipelines Post Office Post Offices post() (IPostOffice method) (PostOffice method) PostOffice (class in m4us.core.postoffices) Producer producer() (in module m4us.core.coroutines)

producer_from_iterable() (in module m4us.core.coroutines) ProducerFinished (class in m4us.core.messages) Producers publish_to() (in module m4us.backplanes) Publisher (class in m4us.backplanes) publisher (IRegisterPublisher attribute) (IUnregisterPublisher attribute) (RegisterPublisher attribute) (UnregisterPublisher attribute) Publishers Python Enhancement Proposals PEP 255 PEP 342, [1]

R

register() (IPostOffice method) (IScheduler method) (PostOffice method) (Scheduler method) RegisterPublisher (class in m4us.backplanes)

retrieve() (IPostOffice method) (PostOffice method) run() (in module m4us.tests) (IScheduler method) (Scheduler method)

S

sample_coroutine() (in module m4us.core.coroutines) SampleComponent (class in m4us.core.components) Scheduler (class in m4us.core.schedulers) Schedulers send() (Component method) (ICoroutine method) (ThreadedCoroutine method) Shutdown (class in m4us.core.messages) Sink

sink() (in module m4us.core.coroutines) sink_from_callable() (in module m4us.core.coroutines) Source start() (IThreadedCoroutine method) (ThreadedCoroutine method) step() (IScheduler method) (Scheduler method) Subscriber Subscribers

T

ThreadedCoroutine (class in m4us.concurrency)

throw() (Component method) (ICoroutine method) (ThreadedCoroutine method)

U

unregister() (IPostOffice method) (IScheduler method) (PostOffice method) (Scheduler method)

UnregisterPublisher (class in m4us.backplanes)