File: //usr/lib/python3/dist-packages/twisted/logger/__pycache__/_observer.cpython-38.pyc
U
�b� � @ s~ d Z ddlmZmZ ddlmZ ddlmZ ddlm Z m
Z
ddl m Z dZ
ee �G d d
� d
��Zee �e
d d �d
d��Zd S )z
Basic log observers.
� )�Callable�Optional)� implementer)�Failure� )� ILogObserver�LogEvent)�LoggerzITemporarily disabling observer {observer} due to exception: {log_failure}c @ s` e Zd ZdZedd�dd�Zedd�dd�Zedd�d d
�Zedd �d d
�Z ee
d�dd�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.
N)� observers�returnc 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 r c C s0 t |�std|����|| jkr,| j�|� 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 n tk
r$ Y nX dS )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��eventr c s� d� krd}nt dd�� �fdd� }g }�jD ]F}|dk rB||� z |� � W q. tk
rr |�|t� f� Y q.X q.|D ]"\}}��|�}|jt||d� qzdS )z8
Forward events to contained observers.
� log_traceNr 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# ZbrokenObserversr ZbrokenObserverr$ Z 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 | ]}|� k r|V qd S )Nr )�.0Zobsr
r r � <genexpr>g s z7LogPublisher._errorLoggerForObserver.<locals>.<genexpr>r
)r
r r )r r ZerrorPublisherr 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
Nr c C s dS )zD
I{ILogObserver} that does nothing with the events it sees.
Nr )r r r r �bitbucketLogObserverl s r/ )r. �typingr r �zope.interfacer �twisted.python.failurer � _interfacesr r �_loggerr r' r
r/ r r r r �<module> s �U