From 866df2dee38ea0789726e02e374fa9e742468687 Mon Sep 17 00:00:00 2001
From: Matthias Bisping <matthias.bisping@iqser.com>
Date: Fri, 6 May 2022 23:07:46 +0200
Subject: [PATCH] renaming

---
 pyinfra/server/server.py | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/pyinfra/server/server.py b/pyinfra/server/server.py
index a9c3f44..1fe9a54 100644
--- a/pyinfra/server/server.py
+++ b/pyinfra/server/server.py
@@ -24,7 +24,7 @@ def make_processor_fn(operation, buffer_size, batched):
     return operation
 
 
-class Processor(abc.ABC):
+class OnDemandProcessor(abc.ABC):
     def __init__(self, processor_fn):
         self.execution_queue = chain([])
         self.processor_fn = processor_fn
@@ -41,7 +41,7 @@ class Processor(abc.ABC):
             return Nothing
 
 
-class ProcessorAdapter(abc.ABC):
+class OnDemandProcessorAdapter(abc.ABC):
     @abc.abstractmethod
     def submit(self, *args, **kwargs) -> None:
         raise NotImplementedError
@@ -51,8 +51,8 @@ class ProcessorAdapter(abc.ABC):
         return result
 
 
-class RestProcessorAdapter(ProcessorAdapter):
-    def __init__(self, processor: Processor):
+class RestProcessorAdapter(OnDemandProcessorAdapter):
+    def __init__(self, processor: OnDemandProcessor):
         self.processor = processor
 
     def submit(self, request) -> None:
@@ -60,7 +60,9 @@ class RestProcessorAdapter(ProcessorAdapter):
 
 
 class RestStreamer:
-    def __init__(self, processor: Processor):
+    """Wraps an on-demand-processor. Combine with a webserver that provides the endpoints 'submit' and 'pickup'."""
+
+    def __init__(self, processor):
         self.processor = processor
 
     def submit(self, request):
@@ -91,7 +93,7 @@ def valid(result):
 
 def set_up_processing_server(process_fn):
     app = Flask(__name__)
-    streamer = RestStreamer(RestProcessorAdapter(Processor(process_fn)))
+    streamer = RestStreamer(RestProcessorAdapter(OnDemandProcessor(process_fn)))
 
     @app.route("/ready", methods=["GET"])
     def ready():