[Fix] Response Streaming Not Working as Expected

Author: juncaipeng

docs/guides/function_calling.md

@@ -111,7 +111,7 @@ def get_current_temperature(location: str, unit: str) -> dict:
 name2function = {"get_current_temperature": get_current_temperature}
 func = name2function[function_call["name"]]
 args = json.loads(function_call["arguments"])
-res = get_current_temperature(location=args["location"], unit=args["unit"])
+res = func(location=args["location"], unit=args["unit"])
 ```
 
 将模型上一轮的响应以及函数的响应加入到对话上下文信息中，再次传递给模型。如果函数的响应不是JSON格式的字符串，需要先对其进行编码。

erniebot/client.py

@@ -147,8 +147,9 @@ def request(
         if stream != got_stream:
             logger.error("Unexpected response: %s", resp)
             raise RuntimeError(
-                "Streaming response is expected, but got non-streaming response. This may indicate a bug in erniebot."
-            )
+                f"A {'streamed' if stream else 'non-streamed'} response was expected, "
+                f"but got a {'streamed' if got_stream else 'non-streamed'} response. "
+                "This may indicate a bug in erniebot.")
         return resp
 
     @overload
@@ -226,8 +227,9 @@ async def arequest(
             if stream != got_stream:
                 logger.error("Unexpected response: %s", resp)
                 raise RuntimeError(
-                    "Streaming response is expected, but got non-streaming response. This may indicate a bug in erniebot."
-                )
+                    f"A {'streamed' if stream else 'non-streamed'} response was expected, "
+                    f"but got a {'streamed' if got_stream else 'non-streamed'} response. "
+                    "This may indicate a bug in erniebot.")
         except Exception as e:
             await ctx.__aexit__(None, None, None)
             raise e
@@ -300,7 +302,6 @@ def request_raw(
             raise errors.ConnectionError(
                 f"Error communicating with server: {e}") from e
 
-        logger.debug("API response body: %r", result.content)
         logger.debug("API response headers: %r", result.headers)
 
         return result
@@ -340,7 +341,6 @@ async def arequest_raw(
             raise errors.ConnectionError(
                 f"Error communicating with server: {e}") from e
 
-        logger.debug("API response body: %r", result.content)
         logger.debug("API response headers: %r", result.headers)
 
         return result
@@ -406,10 +406,11 @@ def _validate_headers(
     def _parse_line(self, line: bytes) -> Optional[str]:
         if line:
             if line.startswith(b"data: "):
+                # Data-only messages
                 line = line[len(b"data: "):]
                 return line.decode('utf-8')
             else:
-                # Filter out empty lines
+                # Filter out other lines
                 return None
         return None