Skip to content

Commit 8067c60

Browse files
committed
refactor: update variable from flushings to chunks_to_flush
1 parent 9197fa7 commit 8067c60

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

slack_sdk/web/chat_stream.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -196,17 +196,17 @@ def stop(
196196

197197
def _flush_buffer(self, chunks: Optional[Sequence[Union[Dict, Chunk]]] = None, **kwargs) -> SlackResponse:
198198
"""Flush the internal buffer with chunks by making appropriate API calls."""
199-
flushings: List[Union[Dict, Chunk]] = []
199+
chunks_to_flush: List[Union[Dict, Chunk]] = []
200200
if len(self._buffer) != 0:
201-
flushings.append(MarkdownTextChunk(text=self._buffer))
201+
chunks_to_flush.append(MarkdownTextChunk(text=self._buffer))
202202
if chunks is not None:
203-
flushings.extend(chunks)
203+
chunks_to_flush.extend(chunks)
204204
if not self._stream_ts:
205205
response = self._client.chat_startStream(
206206
**self._stream_args,
207207
token=self._token,
208208
**kwargs,
209-
chunks=flushings,
209+
chunks=chunks_to_flush,
210210
)
211211
self._stream_ts = response.get("ts")
212212
self._state = "in_progress"
@@ -216,7 +216,7 @@ def _flush_buffer(self, chunks: Optional[Sequence[Union[Dict, Chunk]]] = None, *
216216
channel=self._stream_args["channel"],
217217
ts=self._stream_ts,
218218
**kwargs,
219-
chunks=flushings,
219+
chunks=chunks_to_flush,
220220
)
221221
self._buffer = ""
222222
return response

0 commit comments

Comments
 (0)