Class MockStreamImpl

tests/unit/openai_stream_test.cpp:94–101

Mock Stream Implementation Tests

  EXPECT_THAT(error_data, testing::HasSubstr("Stream error"));
}

TEST_F(StreamEventTest, ParsesFragmentedToolCall) {
  openai::OpenAIStreamImpl stream;
  stream.process_sse_line_for_testing(
      R"(data: {"choices":[{"delta":{"tool_calls":[{"index":0,"id":"call_123","type":"function","function":{"name":"get_weather","arguments":"{\"loc"}}]}}]})");
  stream.process_sse_line_for_testing(
      R"(data: {"choices":[{"delta":{"tool_calls":[{"index":0,"function":{"arguments":"ation\":\"Chicago\"}"}}]},"finish_reason":"tool_calls"}]})");
  stream.process_sse_line_for_testing("data: [DONE]");

  auto tool_event = stream.get_next_event();
  ASSERT_TRUE(tool_event.is_tool_call());