Skip to content

Commit b9c6ff7

Browse files
committed
Bump version to 2.3.2
1 parent 0ce23fa commit b9c6ff7

File tree

4 files changed

+6
-7
lines changed

4 files changed

+6
-7
lines changed

VERSION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
2.3.1
1+
2.3.2

pyproject.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[project]
22
name = "sse-starlette"
3-
version = "2.3.1"
3+
version = "2.3.2"
44
description = "SSE plugin for Starlette"
55
readme = "README.md"
66
license = {text = "BSD-3-Clause"}
@@ -60,7 +60,7 @@ requires = ["setuptools"]
6060
build-backend = "setuptools.build_meta"
6161

6262
[tool.bumpversion]
63-
current_version = "2.3.1"
63+
current_version = "2.3.2"
6464
commit = true
6565
tag = false
6666
message = "Bump version to {new_version}"

sse_starlette/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,4 +2,4 @@
22
from sse_starlette.sse import EventSourceResponse
33

44
__all__ = ["EventSourceResponse", "ServerSentEvent"]
5-
__version__ = "2.3.1"
5+
__version__ = "2.3.2"

sse_starlette/sse.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ def __init__(
8484
Callable[[], Coroutine[None, None, None]]
8585
] = None,
8686
send_timeout: Optional[float] = None,
87-
client_close_handler_callable: Optional[Callable[[Message], None]] = None
87+
client_close_handler_callable: Optional[Callable[[Message], None]] = None,
8888
) -> None:
8989
# Validate separator
9090
if sep not in (None, "\r\n", "\r", "\n"):
@@ -171,15 +171,14 @@ async def _stream_response(self, send: Send) -> None:
171171
self.active = False
172172
await send({"type": "http.response.body", "body": b"", "more_body": False})
173173

174-
175174
async def _listen_for_disconnect(self, receive: Receive) -> None:
176175
"""Watch for a disconnect message from the client."""
177176
while self.active:
178177
message = await receive()
179178
if message["type"] == "http.disconnect":
180179
self.active = False
181180
logger.debug("Got event: http.disconnect. Stop streaming.")
182-
if (self.client_close_handler_callable):
181+
if self.client_close_handler_callable:
183182
await self.client_close_handler_callable(message)
184183
break
185184

0 commit comments

Comments
 (0)