fix(stream): use subscribeOn instead of publishOn for blocking stream sources

[AlbumenJ]

No description provided.

[Copilot]

Pull request overview

This PR fixes threading issues in streaming operations by replacing publishOn with subscribeOn when working with blocking stream sources. The change ensures that blocking I/O operations and synchronous data source iteration happen on appropriate thread pools rather than blocking reactive pipelines.

• Corrects scheduler usage for Flux sources that perform blocking operations (HTTP streaming, Java Stream/Iterable conversion)
• Applies the fix across multiple model implementations and HTTP transport layers
• Updates 6 files with consistent scheduler pattern changes

Reviewed changes

Copilot reviewed 6 out of 6 changed files in this pull request and generated 1 comment.

Show a summary per file

File	Description
agentscope-core/src/main/java/io/agentscope/core/model/transport/OkHttpTransport.java	Changes streaming HTTP SSE handling to use subscribeOn for blocking BufferedReader operations
agentscope-examples/model-request-compression/src/main/java/io/agentscope/examples/compression/extra/CompressingOkHttpTransport.java	Same streaming fix for compressed HTTP transport variant
agentscope-core/src/main/java/io/agentscope/core/model/OpenAIChatModel.java	Fixes scheduler for Flux.fromStream() conversion from OpenAI SDK's blocking Stream
agentscope-core/src/main/java/io/agentscope/core/model/GeminiChatModel.java	Fixes scheduler for Flux.fromIterable() conversion from Gemini's ResponseStream
agentscope-core/src/main/java/io/agentscope/core/model/AnthropicChatModel.java	Fixes scheduler for Flux.fromStream() conversion from Anthropic SDK's blocking Stream
agentscope-core/src/main/java/io/agentscope/core/agent/AgentBase.java	Changes event stream creation scheduler, though this source is reactive rather than blocking

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[codecov]

Codecov Report

❌ Patch coverage is 20.00000% with 4 lines in your changes missing coverage. Please review.

Files with missing lines	Patch %	Lines
...a/io/agentscope/core/model/AnthropicChatModel.java	0.00%	2 Missing ⚠️
...java/io/agentscope/core/model/GeminiChatModel.java	0.00%	1 Missing ⚠️
...java/io/agentscope/core/model/OpenAIChatModel.java	0.00%	1 Missing ⚠️

📢 Thoughts on this report? Let us know!