Another catch

Author: blast-hardcheese

src/replit_river/v2/session.py

@@ -832,6 +832,10 @@ async def send_upload[I, R, A](
                     span=span,
                 )
                 raise
+            except SessionClosedRiverServiceException as e:
+                raise RiverServiceException(
+                    ERROR_CODE_STREAM_CLOSED, str(e), service_name, procedure_name
+                ) from e
             except Exception as e:
                 # If we get any exception other than WebsocketClosedException,
                 # cancel the stream.