Skip to content

Commit b493ec8

Browse files
committed
Fix SSE test.
1 parent 22b6107 commit b493ec8

File tree

1 file changed

+12
-7
lines changed

1 file changed

+12
-7
lines changed

apps/sse_contract_test_service/bin/sse_contract_test_service.dart

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -65,13 +65,18 @@ class TestApiImpl extends TestApi {
6565
httpMethod: method,
6666
headers: headers);
6767
final subscription = client.stream.listen((event) {
68-
callbackClient.callbackNumberPost(
69-
PostCallback(
70-
kind: 'event',
71-
event: PostCallbackEvent(
72-
type: event.type, data: event.data, id: event.id)),
73-
callbackNumber: callbackId);
74-
callbackId++;
68+
switch (event) {
69+
case MessageEvent():
70+
callbackClient.callbackNumberPost(
71+
PostCallback(
72+
kind: 'event',
73+
event: PostCallbackEvent(
74+
type: event.type, data: event.data, id: event.id)),
75+
callbackNumber: callbackId);
76+
callbackId++;
77+
default:
78+
break;
79+
}
7580
}, onError: (error) {
7681
callbackClient.callbackNumberPost(
7782
PostCallback(kind: 'error', comment: error.toString()),

0 commit comments

Comments
 (0)