
    5jG
                         S SK Jr  SSKJr  SSKJr  SSKJr  SSKJ	r	J
r
  SSKJr  \(       a  SS	KJr  SS
KJr  SSKJr  SSKJr   " S S\	5      rg)    )TYPE_CHECKING   OMMListenersUniverseStm)UniverseRecord   )cached_property)PrvOMMStreamget_service_and_details_ommPrvOMMStreamEvts)_UniverseStreams)ExtendedParams)ContentType)Sessionc                       \ rS rSr\r    SSSS\SSSS	S
\S\S\SS4S jjrS r	S r
S rS rS rS rS rS r\S\4S j5       r\S\4S j5       rSrg)_UniverseStream   Ncontent_typer   namesessionr   ownerr   fieldsserviceapiextended_paramsr   c	                 .   Uc  [        S5      eUR                  5       n	U R                  R                   SUR                   SU	 SU S3U l        [        XXg5      u  pjU R                  U5      U l        [        R                  " U U	UUU
SUUUS9	  X@l        g )Nz Instrument name must be defined.z
 owner.id=z id=z name=''MarketPrice)	stream_idr   r   detailsdomainr   r   r   )AttributeError_get_omm_stream_id	__class____name__id	classnamer   record_classrecordr
   __init__r   )selfr   r   r   r   r   r   r   r   r    r!   s              a/root/lseg-credit/backend/venv/lib/python3.13/site-packages/lseg/data/content/_universe_stream.pyr+   _UniverseStream.__init__   s     < !CDD..0	!%!8!8 9EHH:TR[Q\\cdhciijk6|g[&*&7&7&? +
	
 
    c                 6    U R                   R                  5       $ N)r*   get_fields_keysr,   s    r-   keys_UniverseStream.keys2   s    {{**,,r/   c                 6    U R                   R                  5       $ r1   )r*   get_fields_valuesr3   s    r-   values_UniverseStream.values5   s    {{,,..r/   c                 6    U R                   R                  5       $ r1   )r*   get_fields_itemsr3   s    r-   items_UniverseStream.items8   s    {{++--r/   c                 6    U R                   R                  5       $ r1   )r*   __iter__r3   s    r-   r?   _UniverseStream.__iter__;   s    {{##%%r/   c                 8    U R                   R                  U5      $ r1   )r*   __getitem__)r,   fields     r-   rB   _UniverseStream.__getitem__>   s    {{&&u--r/   c                 R    U R                   (       a  [        U R                   5      $ S$ )Nr   )r   lenr3   s    r-   __len___UniverseStream.__len__A   s    #';;s4;;5A5r/   c                 x    [        U R                  U R                  U R                  R	                  5       S.5      $ )N)r   r   r   )strr   r   r*   
get_fieldsr3   s    r-   __repr___UniverseStream.__repr__D   s)    DII$,,$++J`J`Jbcddr/   c                     U R                   =(       d    S SU R                   3nSR                  S U R                  R	                  5        5       5      nU SU S3$ )NzUnknown service|,c              3   4   #    U  H  u  pU S U 3v   M     g7f):N ).0fvs      r-   	<genexpr>*_UniverseStream.__str__.<locals>.<genexpr>I   s     O6Nda!AaSz6Ns   [])r   r   joinr*   rK   )r,   service_namefield_values      r-   __str___UniverseStream.__str__G   sU    ,,;*;<Adii[IhhOdkk6L6L6NOOqQ//r/   returnc                     [        U 5      $ r1   r   r3   s    r-   events_UniverseStream.eventsL   s    %%r/   c                     [        U 5      $ r1   r   r3   s    r-   cxn_listeners_UniverseStream.cxn_listenersP   s    &t,,r/   )r(   r   r*   )NNNN)r&   
__module____qualname____firstlineno__r   r)   rJ   listr+   r4   r8   r<   r?   rB   rG   rL   r^   r	   r   rb   r   re   __static_attributes__rS   r/   r-   r   r      s    !L ,0#  	
 "    *>-/.&.6e0
 &( & & -6 - -r/   r   N)typingr   
_listenersr   _recordr   _toolsr	   delivery._streamr
   r   delivery._stream.eventsr   _universe_streamsr   _typesr   _content_typer   _core.sessionr   r   rS   r/   r-   <module>rv      s4      / # $ H 63'+'B-l B-r/   