Skip to content

Stream

autogen.beta.context.Stream #

Bases: Protocol

id instance-attribute #

id

send async #

send(event, context)
Source code in autogen/beta/context.py 
25
async def send(self, event: BaseEvent, context: "Context") -> None: ...

where #

where(condition)
Source code in autogen/beta/context.py 
27
def where(self, condition: ClassInfo | Condition) -> "Stream": ...

join #

join(*, max_events=None)
Source code in autogen/beta/context.py 
29
30
31
32
33
def join(
    self,
    *,
    max_events: int | None = None,
) -> AbstractContextManager[AsyncIterator[BaseEvent]]: ...

subscribe #

subscribe(func: Callable[..., Any], *, interrupt: bool = False, sync_to_thread: bool = True, condition: Condition | None = None) -> SubId

subscribe(func: None = None, *, interrupt: bool = False, sync_to_thread: bool = True, condition: Condition | None = None) -> Callable[[Callable[..., Any]], SubId]

subscribe(func=None, *, interrupt=False, sync_to_thread=True, condition=None)
Source code in autogen/beta/context.py 
55
56
57
58
59
60
61
62
def subscribe(
    self,
    func: Callable[..., Any] | None = None,
    *,
    interrupt: bool = False,
    sync_to_thread: bool = True,
    condition: Condition | None = None,
) -> Callable[[Callable[..., Any]], SubId] | SubId: ...

unsubscribe #

unsubscribe(sub_id)
Source code in autogen/beta/context.py 
64
def unsubscribe(self, sub_id: SubId) -> None: ...

sub_scope #

sub_scope(func, *, interrupt=False, sync_to_thread=True, condition=None)
Source code in autogen/beta/context.py 
66
67
68
69
70
71
72
73
def sub_scope(
    self,
    func: Callable[..., Any],
    *,
    interrupt: bool = False,
    sync_to_thread: bool = True,
    condition: Condition | None = None,
) -> AbstractContextManager[None]: ...

get #

get(condition)
Source code in autogen/beta/context.py 
75
76
77
78
def get(
    self,
    condition: ClassInfo | Condition,
) -> AbstractAsyncContextManager[asyncio.Future[BaseEvent]]: ...