ChatModelBase

直接消费模型流Consume the raw model stream

import io.agentscope.core.message.Msg;
import io.agentscope.core.message.MsgRole;
import io.agentscope.core.model.ChatModelBase;
import io.agentscope.core.model.ChatResponse;
import io.agentscope.core.model.GenerateOptions;
import io.agentscope.extensions.model.openai.OpenAIChatModel;
import java.util.List;
import reactor.core.publisher.Flux;

public class ModelStreamDemo {
    public static void main(String[] args) {
        ChatModelBase model = OpenAIChatModel.builder()
                .apiKey(System.getenv("OPENAI_API_KEY"))
                .modelName("gpt-4.1-mini")
                .build();

        Flux<ChatResponse> chunks = model.stream(
                List.of(Msg.builderForRole(MsgRole.USER)
                        .name("user")
                        .textContent("Hello")
                        .build()),
                List.of(),
                GenerateOptions.builder().build());

        chunks.doOnNext(chunk -> System.out.println(chunk.getContent()))
                .blockLast();
    }
}