This is an automated email from the ASF dual-hosted git repository. humbedooh pushed a commit to branch humbedooh/mbox-stream in repository https://gitbox.apache.org/repos/asf/incubator-ponymail-foal.git
commit 56f421f17706d5d362b61cabc4811331003c932e Author: Daniel Gruno <[email protected]> AuthorDate: Tue Sep 7 08:22:19 2021 -0500 Create a streaming endpoint type --- server/plugins/server.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/server/plugins/server.py b/server/plugins/server.py index ae5be2f..c03e7d3 100644 --- a/server/plugins/server.py +++ b/server/plugins/server.py @@ -34,6 +34,13 @@ class Endpoint: self.exec = executor +class StreamingEndpoint: + exec: typing.Callable + + def __init__(self, executor): + self.exec = executor + + class BaseServer: """Main server class, base def""" @@ -44,3 +51,4 @@ class BaseServer: database: AsyncElasticsearch dbpool: asyncio.Queue runners: plugins.offloader.ExecutorPool + streamlock: asyncio.Lock
