rsb.transport.local

This package contains a highly efficient in-process transport implementation which allows participants inside one python process to communicate without serialization overhead.

Code author: jwienke

Functions

RLock(*args, **kwargs) Factory function that returns a new reentrant lock.
initialize()

Classes

Bus() Singleton-like representation of the local bus.
InConnector([bus, converters, options]) InConnector for the local transport.
OutConnector([bus, converters, options]) In-process OutConnector.
TransportFactory TransportFactory implementation for the local transport.
class rsb.transport.local.Bus

Bases: object

Singleton-like representation of the local bus.

Code author: jwienke

addSink(sink)

Adds a sink for events pushed to the Bus.

Parameters:sink – the sink to add
getTransportURL()
handle(event)

Dispatches the provided event to all sinks of the appropriate scope.

Parameters:event (rsb.Event) – event to dispatch
removeSink(sink)

Removes a sink to not be notified anymore.

Parameters:sink – sink to remove
class rsb.transport.local.InConnector(bus=<rsb.transport.local.Bus object>, converters=None, options=None, **kwargs)

Bases: rsb.transport.InConnector

InConnector for the local transport.

Code author: jwienke

activate()
deactivate()
filterNotify(filter, action)
getScope()
getTransportURL()
getWireType()

Returns the serialization type used for this connector.

Returns:python serialization type
handle(event)
setObserverAction(action)
setQualityOfServiceSpec(qos)
setScope(scope)
scope
wireType

Returns the serialization type used for this connector.

Returns:python serialization type
class rsb.transport.local.OutConnector(bus=<rsb.transport.local.Bus object>, converters=None, options=None, **kwargs)

Bases: rsb.transport.OutConnector

In-process OutConnector.

Code author: jwienke

activate()
deactivate()
getScope()
getTransportURL()
getWireType()

Returns the serialization type used for this connector.

Returns:python serialization type
handle(event)
setQualityOfServiceSpec(qos)
setScope(newValue)

Sets the scope this connector will receive events from to newValue. Called before #activate.

Parameters:newValue (rsb.Scope) – scope of the connector
scope
wireType

Returns the serialization type used for this connector.

Returns:python serialization type
class rsb.transport.local.TransportFactory

Bases: rsb.transport.TransportFactory

TransportFactory implementation for the local transport.

Code author: jwienke

createInPushConnector(converters, options)
createOutConnector(converters, options)
getName()
isRemote()
rsb.transport.local.initialize()