Ë
    ÛJêj~  ã                  óX   — d Z ddlmZ ddlmZmZ ddlmZmZm	Z	 e	 G d„ de«      «       Z
y)z,EventBusProvider - NATS/Redis Streams/other.é    )Úannotations)Ú	AwaitableÚCallable)ÚAnyÚProtocolÚruntime_checkablec                  ób   — e Zd ZdZed	d„«       Zd
d„Zd
d„Z	 	 	 	 	 	 dd„Z	 	 	 	 	 	 dd„Z	dd„Z
y)ÚEventBusProviderz†Provider for distributed event bus.

    Backends may include NATS, Redis Streams, Kafka, or other
    message streaming systems.
    c                 ó   — y ©N© ©Úselfs    úU/home/oem/CyberBrain26-unified/src/cyberbrain26/extension_layer/event_bus_provider.pyÚprovider_namezEventBusProvider.provider_name   s   € àó    c              ƒ  ó   K  — y ­wr   r   r   s    r   ÚconnectzEventBusProvider.connect   ó	   è ø€ Øùó   ‚c              ƒ  ó   K  — y ­wr   r   r   s    r   Ú
disconnectzEventBusProvider.disconnect   r   r   c              ƒ  ó   K  — y ­wr   r   )r   ÚtopicÚpayloads      r   ÚpublishzEventBusProvider.publish   ó   è ø€ ð
 	ùr   c              ƒ  ó   K  — y ­wr   r   )r   r   Úhandlers      r   Ú	subscribezEventBusProvider.subscribe!   r   r   c              ƒ  ó   K  — y ­wr   r   )r   Úsubscription_ids     r   ÚunsubscribezEventBusProvider.unsubscribe(   r   r   N)ÚreturnÚstr)r$   ÚNone)r   r%   r   zdict[str, Any]r$   Úbool)r   r%   r   z*Callable[[dict[str, Any]], Awaitable[Any]]r$   r%   )r"   r%   r$   r'   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__Úpropertyr   r   r   r   r    r#   r   r   r   r
   r
      sl   „ ñð òó ðóóðàðð  ðð 
ó	ðàðð <ðð 
ó	ôr   r
   N)r+   Ú
__future__r   Úcollections.abcr   r   Útypingr   r   r   r
   r   r   r   ú<module>r0      s/   ðÙ 2Ý "ç /ß 3Ñ 3ð ô �xó  ó ñ r   