add queueing and multi process

example.py

@@ -1,6 +1,8 @@
+import time
 from potassium import Potassium, Request, Response
 from transformers import pipeline
 import torch
+import os
 
 app = Potassium("my_app")
 
@@ -28,5 +30,19 @@ def handler(context: dict, request: Request) -> Response:
         status=200
     )
 
+@app.handler("/stream")
+def stream(context: dict, request: Request):
+    def stream():
+        for i in range(100):
+            yield f"{i}\n"
+            time.sleep(1)
+
+    return Response(
+        body=stream(),
+        status=200,
+        headers={"Content-Type": "text/plain"}
+    )
+
+
 if __name__ == "__main__":
-    app.serve()
+    app.serve()

potassium/__init__.py

@@ -1,3 +1,4 @@
 from .potassium import *
 from .hooks import *
-from .store import Store, RedisConfig
+from .store import Store, RedisConfig
+from .types import Request, Response

potassium/exceptions.py

@@ -0,0 +1,10 @@
+class InvalidEndpointTypeException(Exception):
+    def __init__(self):
+        super().__init__("Invalid endpoint type. Must be 'handler' or 'background'")
+
+
+class RouteAlreadyInUseException(Exception):
+    def __init__(self):
+        super().__init__("Route already in use")
+
+