U


W[��@sHdZd
dl
mZ
d
dlmZ
ddlmZ
dZee�
Gdd�de��
Z	d	S)
z'
Log observer that maintains a buffer.
�)
�deque)
�implementer�
)
�ILogObserveri
c@s,eZ
dZd
Zef
dd�
Zdd�Zdd�ZdS)	�LimitedHistoryLogObservera�

    L{ILogObserver} that stores events in a buffer of a fixed size::

        >>> from twisted.logger import LimitedHistoryLogObserver
        >>> history = LimitedHistoryLogObserver(5)
        >>> for n in range(10): history({'n': n})
        ...
        >>> repeats = []
        >>> history.replayTo(repeats.append)
        >>> len(repeats)
        5
        >>> repeats
        [{'n': 5}, {'n': 6}, {'n': 7}, {'n': 8}, {'n': 9}]
        >>>
    cCst|
d
�
|_
dS)z�
        @param size: The maximum number of events to buffer.  If L{None}, the
            buffer is unbounded.
        @type size: L{int}
        )
�maxlenN)r�_buffer)�self�size�r�8/usr/lib/python3/dist-packages/twisted/logger/_buffer.py�__init__&sz"LimitedHistoryLogObserver.__init__cCs|j�
|
�

dS)
N)r�append)r	�eventrrr�__call__/s
z"LimitedHistoryLogObserver.__call__cCs|jD]}|
|�

qd
S)z�
        Re-play the buffered events to another log observer.

        @param otherObserver: An observer to replay events to.
        @type otherObserver: L{ILogObserver}
        N)
r)r	Z
otherObserverrrrr�replayTo3s

z"LimitedHistoryLogObserver.replayToN)�__name__�
__module__�__qualname__�__doc__�_DEFAULT_BUFFER_MAXIMUMr
rrrrrrrs	rN)
r�collectionsrZzope.interfacerZ	_observerrr�objectrrrrr�<module>s