Added Processor which reads manipulate and write

progrmoiz · progrmoiz · commit 188d827ac18e · 2017-11-18T18:15:26.000+05:00
diff --git a/streams.py b/streams.py
@@ -0,0 +1,24 @@
+def processor(reader, converter, writer):
+    while True:
+        data = reader.read()
+        if not data:
+            break
+        data = converter(data)
+        writer.write(data)
+
+
+class Processor:
+    def __init__(self, reader, writer):
+        self.reader = reader
+        self.writer = writer
+
+    def process(self):
+        while True:
+            data = self.reader.readline()
+            if not data:
+                break
+            data = self.converter(data)
+            self.writer.write(data)
+
+    def converter(data):
+        assert False, 'converter must be defined'  # Or raise exception
