[incubator-ponymail-foal] branch humbedooh/mbox-stream created (now 56f421f)

[hu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

humbedooh pushed a change to branch humbedooh/mbox-stream
in repository https://gitbox.apache.org/repos/asf/incubator-ponymail-foal.git.


      at 56f421f  Create a streaming endpoint type

This branch includes the following new commits:

     new 56f421f  Create a streaming endpoint type

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[incubator-ponymail-foal] 01/01: Create a streaming endpoint type

[hu...@apache.org]

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 <hu...@apache.org>
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