method names

Author: blast-hardcheese

tests/v2/test_v2_cancellation.py

@@ -90,7 +90,7 @@ async def handle_server_messages() -> None:
     rpc_task = asyncio.create_task(
         client.send_rpc(
             "test",
-            "bigstream",
+            "cancel_rpc",
             {"ok": True, "payload": {"hello": "world"}},
             lambda x: x,
             lambda x: x,
@@ -218,7 +218,7 @@ async def _upload_chunks() -> AsyncIterator[OuterPayload[dict[Any, Any]]]:
 
         async for chunk in client.send_stream(
             "test",
-            "bigstream",
+            "cancel_stream",
             {},
             _upload_chunks(),
             lambda x: x,
@@ -352,7 +352,7 @@ async def handle_server_messages() -> None:
     async def receive_chunks() -> None:
         async for chunk in client.send_subscription(
             "test",
-            "bigstream",
+            "subscription_cancel",
             {},
             lambda x: x,
             lambda x: x,
@@ -455,7 +455,7 @@ async def upload_chunks() -> AsyncIterator[OuterPayload[dict[Any, Any]]]:
     upload_task = asyncio.create_task(
         client.send_upload(
             "test",
-            "bigstream",
+            "upload_cancel",
             {},
             upload_chunks(),
             lambda x: x,