0x1949 Team - FAZEMRX - MANAGER
Edit File: _observer.cpython-310.pyc
o �b� � @ s� d Z ddlmZmZ ddlmZ ddlmZ ddlm Z m Z ddl m Z dZ ee �G d d � d ��Zee �d e d d fdd��Zd S )z Basic log observers. � )�Callable�Optional)� implementer)�Failure� )� ILogObserver�LogEvent)�LoggerzITemporarily disabling observer {observer} due to exception: {log_failure}c @ sj e Zd ZdZdeddfdd�Zdeddfdd �Zdeddfd d �Zd eddfd d�Z dede fdd�Z dS )� LogPublisherz� I{ILogObserver} that fans out events to other observers. Keeps track of a set of L{ILogObserver} objects and forwards events to each. � observers�returnNc G s t |�| _t| d�| _d S )N��observer)�list� _observersr �log)�selfr � r �:/usr/lib/python3/dist-packages/twisted/logger/_observer.py�__init__ s zLogPublisher.__init__r c C s4 t |�s td|����|| jvr| j�|� dS dS )zq Registers an observer with this publisher. @param observer: An L{ILogObserver} to add. zObserver is not callable: N)�callable� TypeErrorr �append�r r r r r � addObserver# s �zLogPublisher.addObserverc C s( z | j �|� W dS ty Y dS w )zv Unregisters an observer with this publisher. @param observer: An L{ILogObserver} to remove. N)r �remove� ValueErrorr r r r �removeObserver. s �zLogPublisher.removeObserver�eventc s� d� vrd}n dt ddf� �fdd� }g }�jD ]!}|dur"||� z|� � W q ty9 |�|t� f� Y qw |D ]\}}��|�}|jt||d� q<dS )z8 Forward events to contained observers. � log_traceNr r c s � d � �| f� dS )z� Add tracing information for an observer. @param observer: an observer being forwarded to r N)r r �r r r r �traceB s z$LogPublisher.__call__.<locals>.trace)�failurer )r r � Exceptionr r �_errorLoggerForObserverr" �OBSERVER_DISABLED)r r r! �brokenObserversr �brokenObserverr" � errorLoggerr r r �__call__9 s( � ��zLogPublisher.__call__c s" t � fdd�| jD �� }t|d�S )z� Create an error-logger based on this logger, which does not contain the given bad observer. @param observer: The observer which previously had an error. @return: A L{Logger} without the given observer. c 3 s � | ] }|� ur|V qd S )Nr )�.0�obsr r r � <genexpr>g s � z7LogPublisher._errorLoggerForObserver.<locals>.<genexpr>r )r r r )r r �errorPublisherr r r r$ ] s � z$LogPublisher._errorLoggerForObserver) �__name__� __module__� __qualname__�__doc__r r r r r r) r r$ r r r r r s $r r r Nc C s dS )zD I{ILogObserver} that does nothing with the events it sees. Nr )r r r r �bitbucketLogObserverl s r2 )r1 �typingr r �zope.interfacer �twisted.python.failurer � _interfacesr r �_loggerr r% r r2 r r r r �<module> s �U