Source code for malib.utils.io_wrapper.rpc_io_wrapper

from .base_io_wrapper import BaseIOWrapper



[docs]class RpcIOWrapper(BaseIOWrapper):
    def __init__(self, in_stream=None, out_stream=None):
        raise NotImplementedError