Skip to content

Commit 9a93906

Browse files
committed
feat(appserver): bridge turn events to listener
1 parent 101d964 commit 9a93906

1 file changed

Lines changed: 9 additions & 0 deletions

File tree

src/main/java/io/github/easy4j/codex/appserver/CodexAppServerTurn.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -266,6 +266,9 @@ private void onTurnStarted(JsonNode params) {
266266
if (Objects.nonNull(request.getOnTurnStarted())) {
267267
request.getOnTurnStarted().accept(reported);
268268
}
269+
if (Objects.nonNull(request.getListener())) {
270+
request.getListener().onTurnStarted(reported);
271+
}
269272
}
270273
}
271274

@@ -283,6 +286,9 @@ private void onAgentMessageDelta(JsonNode params) {
283286
if (!applied.isEmpty() && Objects.nonNull(request.getOnDelta())) {
284287
request.getOnDelta().accept(applied);
285288
}
289+
if (!applied.isEmpty() && Objects.nonNull(request.getListener())) {
290+
request.getListener().onTextDelta(applied);
291+
}
286292
}
287293

288294
private void onItemCompleted(JsonNode params) {
@@ -297,6 +303,9 @@ private void onItemCompleted(JsonNode params) {
297303
return;
298304
}
299305
String itemId = firstText(item, "id", "itemId", "item_id");
306+
if (Objects.nonNull(request.getListener())) {
307+
request.getListener().onItemCompleted(type, text);
308+
}
300309
if (hasText(itemId) && streamedAgentItemIds.contains(itemId)) {
301310
return;
302311
}

0 commit comments

Comments
 (0)