U  W[@sHdZddlmZddlmZddlmZdZeeGdddeZ d S) z' Log observer that maintains a buffer. )deque) implementer) ILogObserveric@s,eZdZdZefddZddZddZdS) 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)selfsizer 8/usr/lib/python3/dist-packages/twisted/logger/_buffer.py__init__&sz"LimitedHistoryLogObserver.__init__cCs|j|dS)N)rappend)r eventr r r __call__/sz"LimitedHistoryLogObserver.__call__cCs|jD] }||qdS)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 otherObserverrr r r replayTo3s z"LimitedHistoryLogObserver.replayToN)__name__ __module__ __qualname____doc___DEFAULT_BUFFER_MAXIMUMr rrr r r r rs rN) r collectionsrZzope.interfacerZ _observerrrobjectrr r r r s