U c6{i@sZdZddlmZddlmZmZddlmZddlm Z m Z dZ ee Gdd d Z d S) z' Log observer that maintains a buffer. )deque)DequeOptional) implementer) ILogObserverLogEventic@sHeZdZdZefeeddddZeddddZ e dd d d Z dS) 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)sizereturncCst|d|_dS)zx @param size: The maximum number of events to buffer. If L{None}, the buffer is unbounded. )maxlenN)r_buffer)selfr r:/tmp/pip-unpacked-wheel-hfbvu0bz/twisted/logger/_buffer.py__init__%sz"LimitedHistoryLogObserver.__init__)eventr cCs|j|dS)N)r append)rrrrr__call__,sz"LimitedHistoryLogObserver.__call__) otherObserverr cCs|jD] }||qdS)z Re-play the buffered events to another log observer. @param otherObserver: An observer to replay events to. N)r )rrrrrrreplayTo/s z"LimitedHistoryLogObserver.replayTo) __name__ __module__ __qualname____doc___DEFAULT_BUFFER_MAXIMUMrintrrrrrrrrrr sr N) r collectionsrtypingrrZzope.interfacerZ _interfacesrrrr rrrrs