Missing some signatures from #111 (#112)

Why
===

I handled the output types, but not the input types.

This is arguably more onerous for server implementations, but this still
does conform to how grpc server codegen types work today.

What changed
============

For lack of a stable way to say "I will be providing you an
`AsyncIterator[RequestType]`, I don't care if you take other types as
well" we should at the very least conform to the type signature exposed
by grpc codegen.

Test plan
=========

Does bumping this library cause existing modules to typecheck correctly?

Author: blast-hardcheese

replit_river/rpc.py

@@ -9,6 +9,7 @@
     Dict,
     Generic,
     Iterable,
+    Iterator,
     Literal,
     Mapping,
     NoReturn,
@@ -311,7 +312,7 @@ async def wrapped(
 
 def upload_method_handler(
     method: Callable[
-        [AsyncIterator[RequestType], grpc.aio.ServicerContext],
+        [Iterator[RequestType] | AsyncIterator[RequestType], grpc.aio.ServicerContext],
         ResponseType | Awaitable[ResponseType],
     ],
     request_deserializer: Callable[[Any], RequestType],
@@ -388,7 +389,7 @@ async def _convert_outputs() -> None:
 
 def stream_method_handler(
     method: Callable[
-        [AsyncIterator[RequestType], grpc.aio.ServicerContext],
+        [Iterator[RequestType] | AsyncIterator[RequestType], grpc.aio.ServicerContext],
         AsyncIterable[ResponseType],
     ],
     request_deserializer: Callable[[Any], RequestType],

tests/conftest.py

@@ -1,7 +1,7 @@
 import asyncio
 import logging
 from collections.abc import AsyncIterator
-from typing import Any, AsyncGenerator, Literal
+from typing import Any, AsyncGenerator, Iterator, Literal
 
 import nanoid  # type: ignore
 import pytest
@@ -79,18 +79,28 @@ async def subscription_handler(
         yield f"Subscription message {i} for {request}"
 
 
-async def upload_handler(request: AsyncIterator[str], context: Any) -> str:
+async def upload_handler(
+    request: Iterator[str] | AsyncIterator[str], context: Any
+) -> str:
     uploaded_data = []
-    async for data in request:
-        uploaded_data.append(data)
+    if isinstance(request, AsyncIterator):
+        async for data in request:
+            uploaded_data.append(data)
+    else:
+        for data in request:
+            uploaded_data.append(data)
     return f"Uploaded: {', '.join(uploaded_data)}"
 
 
 async def stream_handler(
-    request: AsyncIterator[str], context: GrpcContext
+    request: Iterator[str] | AsyncIterator[str], context: GrpcContext
 ) -> AsyncGenerator[str, None]:
-    async for data in request:
-        yield f"Stream response for {data}"
+    if isinstance(request, AsyncIterator):
+        async for data in request:
+            yield f"Stream response for {data}"
+    else:
+        for data in request:
+            yield f"Stream response for {data}"
 
 
 @pytest.fixture