talksik/stream-chat-flutter
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test: update test for async methods.

Browse Source 
Signed-off-by: xsahil03x <[email protected]>
This commit is contained in:
Sahil Kumar
2023-06-06 16:15:54 +05:30
committed by xsahil03x
parent 5322ad7170
commit 0e67cdacf5
1 changed files with 19 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/stream_chat/test/src/client/client_test.dart
+19 -17
View File
@@ -2579,9 +2579,9 @@ void main() {
await client.openPersistenceConnection(user);
expect(client.persistenceEnabled, isTrue);
expect(() => client.openPersistenceConnection(user), returnsNormally);
expect(() => client.openPersistenceConnection(user), returnsNormally);
expect(() => client.openPersistenceConnection(user), returnsNormally);
await expectLater(client.openPersistenceConnection(user), completes);
await expectLater(client.openPersistenceConnection(user), completes);
await expectLater(client.openPersistenceConnection(user), completes);
},
);
@@ -2592,8 +2592,8 @@ void main() {
await client.openPersistenceConnection(user);
expect(client.persistenceEnabled, isTrue);
expect(
() => client.openPersistenceConnection(user.copyWith(id: 'new-id')),
await expectLater(
client.openPersistenceConnection(user.copyWith(id: 'new-id')),
throwsA(const TypeMatcher<StreamChatError>()),
);
},
@@ -2602,8 +2602,8 @@ void main() {
test(
'''openPersistenceConnection throws an error if chatPersistenceClient is not set''',
() async {
expect(
() => client.openPersistenceConnection(user),
await expectLater(
client.openPersistenceConnection(user),
throwsA(const TypeMatcher<StreamChatError>()),
);
},
@@ -2619,32 +2619,34 @@ void main() {
});
test(
'''closePersistenceConnection does nothing if chatPersistenceClient is not connected''',
'''closePersistenceConnection compeletes normally if chatPersistenceClient is not connected''',
() async {
client.chatPersistenceClient = MockPersistenceClient();
expect(client.persistenceEnabled, isFalse);
expect(client.chatPersistenceClient!.isConnected, isFalse);
expect(() => client.closePersistenceConnection(), returnsNormally);
await expectLater(client.closePersistenceConnection(), completes);
},
);
test(
'''closePersistenceConnection does nothing if chatPersistenceClient is not set''',
'''closePersistenceConnection completes normally if chatPersistenceClient is not set''',
() async {
expect(client.persistenceEnabled, isFalse);
expect(() => client.closePersistenceConnection(), returnsNormally);
await expectLater(client.closePersistenceConnection(), completes);
},
);
test(
'''connectUser should re-use the persistence connection if already connected''',
'''connectUser completes normally if the persistence connection is already connected to the same user''',
() async {
client.chatPersistenceClient = MockPersistenceClient();
await client.openPersistenceConnection(user);
expect(client.persistenceEnabled, isTrue);
await client.connectUser(user, token, connectWebSocket: false);
expect(client.persistenceEnabled, isTrue);
await expectLater(
client.connectUser(user, token, connectWebSocket: false),
completes,
);
},
);
@@ -2655,8 +2657,8 @@ void main() {
await client.openPersistenceConnection(user.copyWith(id: 'new-id'));
expect(client.persistenceEnabled, isTrue);
expect(
() => client.connectUser(user, token, connectWebSocket: false),
await expectLater(
client.connectUser(user, token, connectWebSocket: false),
throwsA(const TypeMatcher<StreamChatError>()),
);
},