malib.utils.io_wrapper.queue_io_wrapper module

class malib.utils.io_wrapper.queue_io_wrapper.QueueIOWrapper(in_queue: multiprocessing.context.BaseContext.Queue, out_queue: multiprocessing.context.BaseContext.Queue)[source]

Bases: malib.utils.io_wrapper.base_io_wrapper.BaseIOWrapper

read()[source]
write(object)[source]

Serialize object and write/send to target uri.