U

�
b��@sZdZd
dl
mZ
d
dlmZmZ
d
dlmZ
ddlm	Z	m
Z

dZee	�
Gdd	�d	��
Zd
S)z'
Log observer that maintains a buffer.
�)
�deque)�Deque�Optional)
�implementer�
)�ILogObserver�LogEventi
c@sHeZ
dZd
Zef
eedd�dd�Zedd�dd�Z	e
dd	�d
d�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}]
        >>>
    N)�size�returncCst|
d
�
|_
dS)zx
        @param size: The maximum number of events to buffer.  If L{None}, the
            buffer is unbounded.
        )
�maxlenN)r�_buffer)�selfr
�r�8/usr/lib/python3/dist-packages/twisted/logger/_buffer.py�__init__%sz"LimitedHistoryLogObserver.__init__)�eventrcCs|j�
|
�

dS)
N)r
�append)rrrrr�__call__,s
z"LimitedHistoryLogObserver.__call__)�
otherObserverrcCs|jD]}|
|�

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

        @param otherObserver: An observer to replay events to.
        N)
r
)rrrrrr�replayTo/s

z"LimitedHistoryLogObserver.replayTo)�__name__�
__module__�__qualname__�__doc__�_DEFAULT_BUFFER_MAXIMUMr�intrrrrrrrrrr	sr	N)
r�collectionsr�typingrr�zope.interfacer�_interfacesrrrr	rrrr�<module>s