| Server IP : 195.114.193.97 / Your IP : 216.73.217.93 Web Server : LiteSpeed System : Linux host 5.15.0-126-generic #136-Ubuntu SMP Wed Nov 6 10:38:22 UTC 2024 x86_64 User : sembi4241 ( 1126) PHP Version : 8.1.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/logger/__pycache__/ |
Upload File : |
o
�b� � @ sZ d Z ddlmZ ddlmZmZ ddlmZ ddlm Z m
Z
dZee �G dd � d ��Zd
S )z'
Log observer that maintains a buffer.
� )�deque)�Deque�Optional)�implementer� )�ILogObserver�LogEventi c @ sN e Zd ZdZefdee ddfdd�Zdeddfdd �Z d
e
ddfdd�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}]
>>>
�size�returnNc C s t |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__% s z"LimitedHistoryLogObserver.__init__�eventc C s | j �|� d S )N)r
�append)r r r r r �__call__, s z"LimitedHistoryLogObserver.__call__�
otherObserverc C s | j D ]}||� qdS )z�
Re-play the buffered events to another log observer.
@param otherObserver: An observer to replay events to.
N)r
)r r r r r r �replayTo/ s
�z"LimitedHistoryLogObserver.replayTo)�__name__�
__module__�__qualname__�__doc__�_DEFAULT_BUFFER_MAXIMUMr �intr r r r r r r r r r s
r N)
r �collectionsr �typingr r �zope.interfacer �_interfacesr r r r r r r r �<module> s