selfhostyourtech/reflector
2
0
Fork 0
mirror of https://github.com/Monadical-SAS/reflector.git synced 2025-12-20 20:29:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

server: make processors in broadcast to be executed in parallel

Browse Source
This commit is contained in:
Mathieu Virbel
2023-10-25 19:49:15 +02:00
committed by Mathieu Virbel
parent 00c06b7971
commit 367912869d
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
server/reflector/processors/base.py
View File

@@ -290,12 +290,12 @@ class BroadcastProcessor(Processor):
processor.set_pipeline(pipeline) processor.set_pipeline(pipeline)
async def _push(self, data): async def _push(self, data):
for processor in self.processors: coros = [processor.push(data) for processor in self.processors]
await processor.push(data) await asyncio.gather(*coros)
async def _flush(self): async def _flush(self):
for processor in self.processors: coros = [processor.flush() for processor in self.processors]
await processor.flush() await asyncio.gather(*coros)
def connect(self, processor: Processor): def connect(self, processor: Processor):
for processor in self.processors: for processor in self.processors:
@@ -333,6 +333,7 @@ class Pipeline(Processor):
self.logger.info("Pipeline created") self.logger.info("Pipeline created")
self.processors = processors self.processors = processors
self.options = None
self.prefs = {} self.prefs = {}
for processor in processors: for processor in processors: