diff --git a/tractor/__init__.py b/tractor/__init__.py index 980c8dc..01d00ec 100644 --- a/tractor/__init__.py +++ b/tractor/__init__.py @@ -18,76 +18,49 @@ tractor: structured concurrent ``trio``-"actors". """ -from exceptiongroup import BaseExceptionGroup +from exceptiongroup import BaseExceptionGroup as BaseExceptionGroup -from ._clustering import open_actor_cluster +from ._clustering import ( + open_actor_cluster as open_actor_cluster, +) from ._context import ( - Context, # the type - context, # a func-decorator + Context as Context, # the type + context as context, # a func-decorator ) from ._streaming import ( - MsgStream, - stream, + MsgStream as MsgStream, + stream as stream, ) from ._discovery import ( - get_arbiter, - find_actor, - wait_for_actor, - query_actor, + get_arbiter as get_arbiter, + find_actor as find_actor, + wait_for_actor as wait_for_actor, + query_actor as query_actor, +) +from ._supervise import ( + open_nursery as open_nursery, + ActorNursery as ActorNursery, ) -from ._supervise import open_nursery from ._state import ( - current_actor, - is_root_process, + current_actor as current_actor, + is_root_process as is_root_process, ) from ._exceptions import ( - RemoteActorError, - ModuleNotExposed, - ContextCancelled, + RemoteActorError as RemoteActorError, + ModuleNotExposed as ModuleNotExposed, + ContextCancelled as ContextCancelled, ) from .devx import ( - breakpoint, - pause, - pause_from_sync, - post_mortem, + breakpoint as breakpoint, + pause as pause, + pause_from_sync as pause_from_sync, + post_mortem as post_mortem, ) -from . import msg +from . import msg as msg from ._root import ( - run_daemon, - open_root_actor, + run_daemon as run_daemon, + open_root_actor as open_root_actor, ) -from ._ipc import Channel -from ._portal import Portal -from ._runtime import Actor - - -__all__ = [ - 'Actor', - 'BaseExceptionGroup', - 'Channel', - 'Context', - 'ContextCancelled', - 'ModuleNotExposed', - 'MsgStream', - 'Portal', - 'RemoteActorError', - 'breakpoint', - 'context', - 'current_actor', - 'find_actor', - 'query_actor', - 'get_arbiter', - 'is_root_process', - 'msg', - 'open_actor_cluster', - 'open_nursery', - 'open_root_actor', - 'pause', - 'post_mortem', - 'pause_from_sync', - 'query_actor', - 'run_daemon', - 'stream', - 'to_asyncio', - 'wait_for_actor', -] +from ._ipc import Channel as Channel +from ._portal import Portal as Portal +from ._runtime import Actor as Actor