handler request class check

sharded_queue/__init__.py

@@ -28,7 +28,10 @@ async def create(cls) -> Self:
 
     @classmethod
     def request_cls(cls) -> type[T]:
-        return list(get_type_hints(cls.handle).values())[0]
+        cls = list(get_type_hints(cls.handle).values())[0]
+        if cls is T:
+            raise NotImplementedError
+        return cls
 
     @classmethod
     async def route(cls, *requests: T) -> list[Route]:
@@ -41,7 +44,7 @@ async def start(self) -> None:
         pass
 
     async def handle(self, *requests: T) -> None:
-        raise NotImplementedError()
+        raise NotImplementedError
 
     async def stop(self) -> None:
         pass

tests/test_handler.py

@@ -0,0 +1,23 @@
+from pytest import mark, raises
+
+from sharded_queue import Handler, Queue, Worker
+from sharded_queue.drivers import RuntimeLock, RuntimeStorage
+from sharded_queue.protocols import Storage
+
+
+class AbstractRequest:
+    ...
+
+
+class AbstractHandler(Handler):
+    ...
+
+
+@mark.asyncio
+async def test_handler() -> None:
+    storage: Storage = RuntimeStorage()
+    queue: Queue = Queue(storage)
+    await queue.register(AbstractHandler, AbstractRequest())
+
+    with raises(NotImplementedError):
+        await Worker(RuntimeLock(), queue).loop(1)