hat.event.manager.server 

 1from collections.abc import Collection
 2
 3from hat.drivers import net
 4
 5from hat.event.manager import common
 6
 7
 8async def run(addr: net.StreamAddress,
 9              client_name: str,
10              client_token: str | None,
11              subscriptions: Collection[common.EventType],
12              server_id: int | None,
13              persisted: bool,
14              http_addr: net.StreamAddress):
15    raise NotImplementedError()
async def run( addr: hat.drivers.net.stream.TcpAddress | pathlib.Path, client_name: str, client_token: str | None, subscriptions: Collection[tuple[str, ...]], server_id: int | None, persisted: bool, http_addr: hat.drivers.net.stream.TcpAddress | pathlib.Path): 
 9async def run(addr: net.StreamAddress,
10              client_name: str,
11              client_token: str | None,
12              subscriptions: Collection[common.EventType],
13              server_id: int | None,
14              persisted: bool,
15              http_addr: net.StreamAddress):
16    raise NotImplementedError()