1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
# SPDX-FileCopyrightText: Christian Amsüss and the aiocoap contributors
#
# SPDX-License-Identifier: MIT
import time
class _Throttler:
"""Wrapper around an argumentless function that silently drops calls if
there are too many."""
# FIXME i'd rather have the ObservableResource or even the observation
# itself handle this
def __init__(self, callback):
self.callback = callback
self.last = 0
def __call__(self):
now = time.time()
if now - self.last < 0.2:
return
self.last = now
self.callback()
|
