fix: support explicit json values as chunk objects

Author: zimeg

slack_sdk/web/chat_stream.py

@@ -67,7 +67,7 @@ def append(
         self,
         *,
         markdown_text: Optional[str] = None,
-        chunks: Optional[Sequence[Chunk]] = None,
+        chunks: Optional[Sequence[Union[Dict, Chunk]]] = None,
         **kwargs,
     ) -> Optional[SlackResponse]:
         """Append to the stream.
@@ -123,7 +123,7 @@ def stop(
         self,
         *,
         markdown_text: Optional[str] = None,
-        chunks: Optional[Sequence[Chunk]] = None,
+        chunks: Optional[Sequence[Union[Dict, Chunk]]] = None,
         blocks: Optional[Union[str, Sequence[Union[Dict, Block]]]] = None,
         metadata: Optional[Union[Dict, Metadata]] = None,
         **kwargs,
@@ -173,7 +173,7 @@ def stop(
                 raise e.SlackRequestError("Failed to stop stream: stream not started")
             self._stream_ts = str(response["ts"])
             self._state = "in_progress"
-        flushings: List[Chunk] = []
+        flushings: List[Union[Dict, Chunk]] = []
         if len(self._buffer) != 0:
             flushings.append(MarkdownTextChunk(text=self._buffer))
         if chunks is not None:
@@ -190,9 +190,9 @@ def stop(
         self._state = "completed"
         return response
 
-    def _flush_buffer(self, chunks: Optional[Sequence[Chunk]] = None, **kwargs) -> SlackResponse:
+    def _flush_buffer(self, chunks: Optional[Sequence[Union[Dict, Chunk]]] = None, **kwargs) -> SlackResponse:
         """Flush the internal buffer with chunks by making appropriate API calls."""
-        flushings: List[Chunk] = []
+        flushings: List[Union[Dict, Chunk]] = []
         if len(self._buffer) != 0:
             flushings.append(MarkdownTextChunk(text=self._buffer))
         if chunks is not None: