Fixed black errors

Author: agronholm

starlette/middleware/base.py

@@ -108,7 +108,8 @@ async def __call__(self, scope: Scope, receive: Receive, send: Send) -> None:
         async def call_next(request: Request) -> Response:
             app_exc: typing.Optional[Exception] = None
             send_stream, recv_stream = anyio.create_memory_object_stream[
-                typing.MutableMapping[str, typing.Any]]()
+                typing.MutableMapping[str, typing.Any]
+            ]()
 
             async def receive_or_disconnect() -> Message:
                 if response_sent.is_set():

starlette/middleware/wsgi.py

@@ -78,9 +78,8 @@ def __init__(self, app: typing.Callable, scope: Scope) -> None:
         self.status = None
         self.response_headers = None
         self.stream_send, self.stream_receive = anyio.create_memory_object_stream[
-            typing.MutableMapping[str, typing.Any]](
-            math.inf
-        )
+            typing.MutableMapping[str, typing.Any]
+        ](math.inf)
         self.response_started = False
         self.exc_info: typing.Any = None
 

starlette/testclient.py

@@ -746,11 +746,13 @@ def reset_portal() -> None:
 
             self.stream_send = StapledObjectStream(
                 *anyio.create_memory_object_stream[
-                    typing.Optional[typing.MutableMapping[str, typing.Any]]](math.inf)
+                    typing.Optional[typing.MutableMapping[str, typing.Any]]
+                ](math.inf)
             )
             self.stream_receive = StapledObjectStream(
                 *anyio.create_memory_object_stream[
-                    typing.MutableMapping[str, typing.Any]](math.inf)
+                    typing.MutableMapping[str, typing.Any]
+                ](math.inf)
             )
             self.task = portal.start_task_soon(self.lifespan)
             portal.call(self.wait_startup)

tests/test_websockets.py

@@ -179,7 +179,9 @@ async def app(scope: Scope, receive: Receive, send: Send) -> None:
 
 
 def test_websocket_concurrency_pattern(test_client_factory):
-    stream_send, stream_receive = anyio.create_memory_object_stream[MutableMapping[str, Any]]()
+    stream_send, stream_receive = anyio.create_memory_object_stream[
+        MutableMapping[str, Any]
+    ]()
 
     async def reader(websocket):
         async with stream_send: