o b@sZdZddlmZddlmZmZddlmZddlm Z m Z dZ ee Gdd d Z d S) z' Log observer that maintains a buffer. )deque)DequeOptional) implementer) ILogObserverLogEventic@sNeZdZdZefdeeddfddZdeddfdd Z d e ddfd 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}] >>> sizereturnNcCst|d|_dS)zx @param size: The maximum number of events to buffer. If L{None}, the buffer is unbounded. )maxlenN)r_buffer)selfr r8/usr/lib/python3/dist-packages/twisted/logger/_buffer.py__init__%sz"LimitedHistoryLogObserver.__init__eventcCs|j|dS)N)r append)rrrrr__call__,sz"LimitedHistoryLogObserver.__call__ otherObservercCs|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 s r N) r collectionsrtypingrrzope.interfacer _interfacesrrrr rrrrs