Multiprocessing app
- class pymoa_remote.app.multiprocessing.ProcessSocketServer(**kwargs)
Bases:
pymoa_remote.server.SimpleExecutorServerQuart server side socket handler.
- await decode(data)
- encode(data)
- post_stream_channel(data, channel, hash_name)
- await read_decode_json_buffers(stream: trio.SocketStream)
- stream_clients = {}
- await write_socket(data: bytes, sock: trio.SocketStream)
- pymoa_remote.app.multiprocessing.run_app()