Multiprocessing app

class pymoa_remote.app.multiprocessing.ProcessSocketServer(**kwargs)

Bases: SimpleExecutorServer

Quart server side socket handler.

await decode(data)

encode(data)

post_stream_channel(data, channel, hash_name)

await read_decode_json_buffers(stream: SocketStream)

stream_clients = {}

await write_socket(data: bytes, sock: SocketStream)

pymoa_remote.app.multiprocessing.run_app()