
    5j                         S SK Jr  S SKJr  SSKJr  SSKJr  \(       a  SSKJ	r	  SSK
Jr  S	\S
\S\SS4S jr " S S\5      rg)    )partialmethod)TYPE_CHECKING   )	StreamEvt)PrvOMMStreamEvts   )_UniverseStream)_UniverseStreamsselfevmessageuniverse_streamr	   c                 f    U R                  XUR                  U R                  R                  5        g )N)dispatchname
originatorowner)r   r   r   r   s       X/root/lseg-credit/backend/venv/lib/python3.13/site-packages/lseg/data/content/_events.pyr   r      s"    MM"33T__5J5JK    c                      \ rS rSrSr\" \\R                  5      r	\" \\R                  5      r\" \R                  \R                  5      r\" \\R                   5      r\" \\R$                  5      r\" \\R(                  5      rSrg)_UniverseStreamsEvts   z'
Events from _UniverseStreams for User
 N)__name__
__module____qualname____firstlineno____doc__r   r   r   REFRESHdispatch_refreshSTATUSdispatch_statusr   _dispatch_ownerCOMPLETEdispatch_completeERRORdispatch_errorUPDATEdispatch_updateACKdispatch_ack__static_attributes__r   r   r   r   r      sz     %Xy/@/@A#Hi.>.>?O%&6&F&F	HZHZ["8Y__=N#Hi.>.>?O 9==9Lr   r   N)	functoolsr   typingr   delivery._streamr   delivery._stream.eventsr   _universe_streamr	   _universe_streamsr
   dictr   r   r   r   r   <module>r4      sO    #   ( 613L# L LT LTe L
:+ 
:r   