Skip to content

Commit 4deb45f

Browse files
Unused extra_control_flags
1 parent 450a05d commit 4deb45f

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

src/replit_river/v2/session.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -714,7 +714,6 @@ async def send_upload[I, R, A](
714714
) from e
715715
await self._send_close_stream(
716716
stream_id=stream_id,
717-
extra_control_flags=0,
718717
span=span,
719718
)
720719

@@ -835,7 +834,6 @@ async def _encode_stream() -> None:
835834
if not request:
836835
await self._send_close_stream(
837836
stream_id=stream_id,
838-
extra_control_flags=STREAM_OPEN_BIT,
839837
span=span,
840838
)
841839
return
@@ -856,7 +854,6 @@ async def _encode_stream() -> None:
856854
)
857855
await self._send_close_stream(
858856
stream_id=stream_id,
859-
extra_control_flags=0,
860857
span=span,
861858
)
862859

@@ -905,12 +902,11 @@ async def _send_cancel_stream(
905902
async def _send_close_stream(
906903
self,
907904
stream_id: str,
908-
extra_control_flags: int,
909905
span: Span,
910906
) -> None:
911907
await self._send_message(
912908
stream_id=stream_id,
913-
control_flags=STREAM_CLOSED_BIT | extra_control_flags,
909+
control_flags=STREAM_CLOSED_BIT,
914910
payload={"type": "CLOSE"},
915911
span=span,
916912
)

0 commit comments

Comments
 (0)