Skip to content

Commit f3ff3d8

Browse files
committed
test: test sendMessageStream fallback to sendMessage
1 parent 0215d42 commit f3ff3d8

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

test/e2e.spec.ts

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -202,6 +202,22 @@ describe('Client E2E tests', () => {
202202

203203
expect(removeUndefinedFields(actual)).to.deep.equal(expected);
204204
});
205+
206+
it('should fallback to non-streaming sendMessage if agent does not support streaming', async () => {
207+
agentCard.capabilities.streaming = false;
208+
const requestMessage = createTestMessage('1', 'request-message');
209+
const responseMessage = createTestMessage('2', 'response-message');
210+
agentExecutor.events = [responseMessage];
211+
const client = await clientFactory.createFromAgentCard(agentCard);
212+
213+
const actual: A2AStreamEventData[] = [];
214+
for await (const message of client.sendMessageStream({ message: requestMessage })) {
215+
actual.push(message);
216+
}
217+
218+
expect(actual).to.have.lengthOf(1);
219+
expect(removeUndefinedFields(actual[0])).to.deep.equal(responseMessage);
220+
});
205221
});
206222
});
207223
});

0 commit comments

Comments
 (0)