libvis.websocket package

Submodules

libvis.websocket.message_gen module

libvis.websocket.message_gen.async_gen(l)[source]
libvis.websocket.message_gen.async_list(agen)[source]
libvis.websocket.message_gen.message_gen(ws)[source]

libvis.websocket.test_ws_server module

libvis.websocket.test_ws_server.test_simple()[source]

libvis.websocket.ws_client module

async libvis.websocket.ws_client.communicate(addr, iterable_fn)[source]
libvis.websocket.ws_client.main(addr='wss://echo.websocket.org', message='hello world')[source]
async libvis.websocket.ws_client.open_ws_wrapper(addr, on_connect, on_error=<function _default_on_error>)[source]
async libvis.websocket.ws_client.send_iter(addr, iterable)[source]
async libvis.websocket.ws_client.send_one(addr, message)[source]
libvis.websocket.ws_client.start_client(addr, iterable_fn)[source]

libvis.websocket.ws_server module

exception libvis.websocket.ws_server.StopServer[source]

Bases: Exception

libvis.websocket.ws_server.main()[source]
libvis.websocket.ws_server.start_server(addr, port, handler_func=<built-in function print>, on_connect=<function <lambda>>)[source]
libvis.websocket.ws_server.start_server_handler(addr, port, handler_func)[source]
libvis.websocket.ws_server.stop()[source]
async libvis.websocket.ws_server.ws_serve(addr, port, iterable_fn, on_connect=<function <lambda>>, nursery=None)[source]

Module contents