ezmsg.zmq.util#

Functions

serialize_msg(msg)[source]#

Parameters:: msg (Any)
Return type:: bytes

Classes

class DeserializeBytes(*args, settings=None, **kwargs)[source]#

Bases: Unit

Parameters:: settings (Settings | None)

INPUT = InputStream:unlocated[bytes]()#

OUTPUT_SIGNAL = OutputStream:unlocated[Any](self.num_buffers=32, self.force_tcp=None, self.allow_local=None)#

async deserialize(msg)[source]#

Parameters:: msg (ZMQMessage)
Return type:: AsyncGenerator

class SerializeMessage(*args, settings=None, **kwargs)[source]#

Bases: Unit

Parameters:: settings (Settings | None)

SETTINGS#: alias of SerializeMessageSettings

INPUT = InputStream:unlocated[Any]()#

OUTPUT = OutputStream:unlocated[ZMQMessage](self.num_buffers=32, self.force_tcp=None, self.allow_local=None)#

async on_message(message)[source]#

Parameters:: message (Any)
Return type:: AsyncGenerator

class SerializeMessageSettings(fun: Callable = <function serialize_msg at 0x7f2a501187c0>)[source]#

Bases: Settings

Parameters:: fun (Callable)

fun()#

Function to serialize the message. Must take a single argument and return a bytes object.

Parameters:: msg (Any)
Return type:: bytes

__init__(fun=<function serialize_msg>)#

Parameters:: fun (Callable)
Return type:: None

class ZMQMessage(data: bytes)[source]#

Bases: object

Parameters:: data (bytes)

data: bytes#

__init__(data)#

Parameters:: data (bytes)
Return type:: None

class ZeroCopyBytes[source]#: Bases: bytes

class ZeroCopyBytes[source]#: Bases: bytes

class ZMQMessage(data: bytes)[source]#

Bases: object

Parameters:: data (bytes)

data: bytes#

__init__(data)#

Parameters:: data (bytes)
Return type:: None

serialize_msg(msg)[source]#

Parameters:: msg (Any)
Return type:: bytes

class SerializeMessageSettings(fun: Callable = <function serialize_msg at 0x7f2a501187c0>)[source]#

Bases: Settings

Parameters:: fun (Callable)

fun()#

Function to serialize the message. Must take a single argument and return a bytes object.

Parameters:: msg (Any)
Return type:: bytes

__init__(fun=<function serialize_msg>)#

Parameters:: fun (Callable)
Return type:: None

class SerializeMessage(*args, settings=None, **kwargs)[source]#

Bases: Unit

Parameters:: settings (Settings | None)

SETTINGS#: alias of SerializeMessageSettings

INPUT = InputStream:unlocated[Any]()#

OUTPUT = OutputStream:unlocated[ZMQMessage](self.num_buffers=32, self.force_tcp=None, self.allow_local=None)#

async on_message(message)[source]#

Parameters:: message (Any)
Return type:: AsyncGenerator

class DeserializeBytes(*args, settings=None, **kwargs)[source]#

Bases: Unit

Parameters:: settings (Settings | None)

INPUT = InputStream:unlocated[bytes]()#

OUTPUT_SIGNAL = OutputStream:unlocated[Any](self.num_buffers=32, self.force_tcp=None, self.allow_local=None)#

async deserialize(msg)[source]#

Parameters:: msg (ZMQMessage)
Return type:: AsyncGenerator