xibus

commit

24c2c9c05150efb10ece28519a0a380750fe2d6f

parent

1b30d5f8d8ec7a3eb34c528132a58f2d8d013b6c

Author

Tobias Bengfort <tobias.bengfort@posteo.de>

Date

2026-02-20 05:41

connection: limit queue size

Diffstat

1 files changed, 4 insertions, 4 deletions

diff --git a/xibus/connection.py b/xibus/connection.py

@@ -125,8 +125,8 @@ class Connection:
  125   125         self.sock = None
  126   126 
  127   127     @contextmanager
  128    -1     def signal_queue(self):
  129    -1         queue = asyncio.Queue()
   -1   128     def signal_queue(self, *, maxsize=32):
   -1   129         queue = asyncio.Queue(maxsize)
  130   130         self.signal_queues.add(queue)
  131   131         try:
  132   132             yield iter_queue(queue)
@@ -134,10 +134,10 @@ class Connection:
  134   134             self.signal_queues.remove(queue)
  135   135 
  136   136     @contextmanager
  137    -1     def call_queue(self, name):
   -1   137     def call_queue(self, name, *, maxsize=32):
  138   138         if name in self.call_queues:
  139   139             raise ValueError(name)
  140    -1         queue = asyncio.Queue()
   -1   140         queue = asyncio.Queue(maxsize)
  141   141         self.call_queues[name] = queue
  142   142         try:
  143   143             yield iter_queue(queue)