We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 45f88f6 commit c113458Copy full SHA for c113458
packages/graphql/test/websocket_test.dart
@@ -613,7 +613,8 @@ Future<void> main() async {
613
operation: Operation(document: gql('subscription {}')),
614
);
615
final waitForConnection = true;
616
- socketClient.subscribe(payload, waitForConnection);
+ var subscription = socketClient.subscribe(payload, waitForConnection);
617
+ var isEmpty = subscription.isEmpty;
618
619
await expectLater(
620
socketClient.connectionState,
@@ -638,6 +639,8 @@ Future<void> main() async {
638
639
640
expect(
641
socketClient.socketChannel!.closeCode, WebSocketStatus.normalClosure);
642
+
643
+ expect(await isEmpty.timeout(const Duration(seconds: 1)), true);
644
});
645
}, tags: "integration");
646
0 commit comments