Skip to content

Commit c9cf449

Browse files
committed
chore: codegen
1 parent 8067c60 commit c9cf449

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

slack_sdk/web/async_chat_stream.py

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

207207
async def _flush_buffer(self, chunks: Optional[Sequence[Union[Dict, Chunk]]] = None, **kwargs) -> AsyncSlackResponse:
208208
"""Flush the internal buffer with chunks by making appropriate API calls."""
209-
flushings: List[Union[Dict, Chunk]] = []
209+
chunks_to_flush: List[Union[Dict, Chunk]] = []
210210
if len(self._buffer) != 0:
211-
flushings.append(MarkdownTextChunk(text=self._buffer))
211+
chunks_to_flush.append(MarkdownTextChunk(text=self._buffer))
212212
if chunks is not None:
213-
flushings.extend(chunks)
213+
chunks_to_flush.extend(chunks)
214214
if not self._stream_ts:
215215
response = await self._client.chat_startStream(
216216
**self._stream_args,
217217
token=self._token,
218218
**kwargs,
219-
chunks=flushings,
219+
chunks=chunks_to_flush,
220220
)
221221
self._stream_ts = response.get("ts")
222222
self._state = "in_progress"
@@ -226,7 +226,7 @@ async def _flush_buffer(self, chunks: Optional[Sequence[Union[Dict, Chunk]]] = N
226226
channel=self._stream_args["channel"],
227227
ts=self._stream_ts,
228228
**kwargs,
229-
chunks=flushings,
229+
chunks=chunks_to_flush,
230230
)
231231
self._buffer = ""
232232
return response

0 commit comments

Comments
 (0)