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[<class 'bytes'>]()#
OUTPUT_SIGNAL = OutputStream:unlocated[typing.Any](self.num_buffers=32, self.force_tcp=False)#
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[typing.Any]()#
OUTPUT = OutputStream:unlocated[<class 'ezmsg.zmq.util.ZMQMessage'>](self.num_buffers=32, self.force_tcp=False)#
async on_message(message)[source]#
Parameters:

message (Any)

Return type:

AsyncGenerator

class SerializeMessageSettings(fun: Callable = <function serialize_msg at 0x7f0966c3cf40>)[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 0x7f0966c3cf40>)[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[typing.Any]()#
OUTPUT = OutputStream:unlocated[<class 'ezmsg.zmq.util.ZMQMessage'>](self.num_buffers=32, self.force_tcp=False)#
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[<class 'bytes'>]()#
OUTPUT_SIGNAL = OutputStream:unlocated[typing.Any](self.num_buffers=32, self.force_tcp=False)#
async deserialize(msg)[source]#
Parameters:

msg (ZMQMessage)

Return type:

AsyncGenerator