@@ -300,7 +300,9 @@ void main() {
|
||||
when(() => mockChannel.state.isUpToDate).thenReturn(false);
|
||||
when(() => mockChannel.initialized).thenAnswer((_) async => true);
|
||||
when(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
messagesPagination: any(named: 'messagesPagination'),
|
||||
preferOffline: any(named: 'preferOffline'),
|
||||
|
||||
@@ -165,7 +165,9 @@ void main() {
|
||||
when(() => mockChannel.initialized).thenAnswer((_) async => true);
|
||||
final messages = _generateMessages();
|
||||
when(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: any(named: 'messagesPagination'),
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
@@ -183,7 +185,9 @@ void main() {
|
||||
|
||||
verify(() => mockChannel.initialized).called(1);
|
||||
verify(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: any(named: 'messagesPagination'),
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
@@ -228,7 +232,9 @@ void main() {
|
||||
final messages = _generateMessages();
|
||||
|
||||
when(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: beforePagination,
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
@@ -236,7 +242,9 @@ void main() {
|
||||
)).thenAnswer((_) async => ChannelState(messages: messages));
|
||||
|
||||
when(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: afterPagination,
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
@@ -259,7 +267,9 @@ void main() {
|
||||
await tester.pumpAndSettle();
|
||||
|
||||
verify(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: beforePagination,
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
@@ -267,7 +277,9 @@ void main() {
|
||||
)).called(1);
|
||||
|
||||
verify(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: afterPagination,
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
@@ -285,7 +297,9 @@ void main() {
|
||||
);
|
||||
|
||||
when(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: updatedBeforePagination,
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
@@ -293,7 +307,9 @@ void main() {
|
||||
)).thenAnswer((_) async => ChannelState(messages: messages));
|
||||
|
||||
when(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: updatedAfterPagination,
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
@@ -303,7 +319,9 @@ void main() {
|
||||
await tester.pumpAndSettle();
|
||||
|
||||
verify(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: updatedBeforePagination,
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
@@ -311,7 +329,9 @@ void main() {
|
||||
)).called(1);
|
||||
|
||||
verify(() => mockChannel.query(
|
||||
options: any(named: 'options'),
|
||||
state: any(named: 'state'),
|
||||
watch: any(named: 'watch'),
|
||||
presence: any(named: 'presence'),
|
||||
messagesPagination: updatedAfterPagination,
|
||||
membersPagination: any(named: 'membersPagination'),
|
||||
watchersPagination: any(named: 'watchersPagination'),
|
||||
|
||||
@@ -227,7 +227,7 @@ void main() {
|
||||
);
|
||||
|
||||
testWidgets(
|
||||
'didChangeAppLifecycleState should not call client.connect() '
|
||||
'didChangeAppLifecycleState should not call client.openConnection() '
|
||||
'if connection is not available in case the '
|
||||
'widget lifestyle changes to AppLifecycleState.resume',
|
||||
(tester) async {
|
||||
@@ -238,8 +238,8 @@ void main() {
|
||||
|
||||
final event = Event();
|
||||
when(() => mockClient.on()).thenAnswer((_) => Stream.value(event));
|
||||
when(() => mockClient.connect()).thenAnswer((_) async => event);
|
||||
when(() => mockClient.disconnect()).thenAnswer((_) async => null);
|
||||
when(() => mockClient.openConnection()).thenAnswer((_) async => event);
|
||||
when(() => mockClient.closeConnection()).thenAnswer((_) async => null);
|
||||
when(() => mockClient.wsConnectionStatus)
|
||||
.thenReturn(ConnectionStatus.disconnected);
|
||||
|
||||
@@ -267,7 +267,7 @@ void main() {
|
||||
streamChatCoreState
|
||||
.didChangeAppLifecycleState(AppLifecycleState.resumed);
|
||||
|
||||
verifyNever(() => mockClient.connect());
|
||||
verifyNever(() => mockClient.openConnection());
|
||||
});
|
||||
},
|
||||
);
|
||||
@@ -327,8 +327,8 @@ void main() {
|
||||
|
||||
final event = Event();
|
||||
when(() => mockClient.on()).thenAnswer((_) => Stream.value(event));
|
||||
when(() => mockClient.connect()).thenAnswer((_) async => event);
|
||||
when(() => mockClient.disconnect()).thenAnswer((_) async => null);
|
||||
when(() => mockClient.openConnection()).thenAnswer((_) async => event);
|
||||
when(() => mockClient.closeConnection()).thenAnswer((_) async => null);
|
||||
when(() => mockClient.wsConnectionStatus)
|
||||
.thenReturn(ConnectionStatus.disconnected);
|
||||
|
||||
@@ -348,7 +348,7 @@ void main() {
|
||||
|
||||
await Future.delayed(const Duration(seconds: 1));
|
||||
|
||||
verify(() => mockClient.connect()).called(1);
|
||||
verify(() => mockClient.openConnection()).called(1);
|
||||
});
|
||||
},
|
||||
);
|
||||
@@ -376,8 +376,8 @@ void main() {
|
||||
|
||||
final event = Event();
|
||||
when(() => mockClient.on()).thenAnswer((_) => Stream.value(event));
|
||||
when(() => mockClient.connect()).thenAnswer((_) async => event);
|
||||
when(mockClient.disconnect).thenAnswer((_) async => null);
|
||||
when(() => mockClient.openConnection()).thenAnswer((_) async => event);
|
||||
when(() => mockClient.closeConnection()).thenAnswer((_) async => null);
|
||||
when(() => mockClient.wsConnectionStatus)
|
||||
.thenReturn(ConnectionStatus.connected);
|
||||
|
||||
@@ -385,7 +385,7 @@ void main() {
|
||||
|
||||
await Future.delayed(const Duration(seconds: 1));
|
||||
|
||||
verify(() => mockClient.disconnect()).called(1);
|
||||
verify(() => mockClient.closeConnection()).called(1);
|
||||
});
|
||||
},
|
||||
);
|
||||
@@ -402,8 +402,8 @@ void main() {
|
||||
|
||||
final event = Event();
|
||||
when(() => mockClient.on()).thenAnswer((_) => Stream.value(event));
|
||||
when(() => mockClient.connect()).thenAnswer((_) async => event);
|
||||
when(() => mockClient.disconnect()).thenAnswer((_) async => null);
|
||||
when(() => mockClient.openConnection()).thenAnswer((_) async => event);
|
||||
when(() => mockClient.closeConnection()).thenAnswer((_) async => null);
|
||||
when(() => mockClient.wsConnectionStatus)
|
||||
.thenReturn(ConnectionStatus.disconnected);
|
||||
|
||||
@@ -432,7 +432,7 @@ void main() {
|
||||
|
||||
await Future.delayed(const Duration(seconds: 1));
|
||||
|
||||
verifyNever(() => mockClient.disconnect());
|
||||
verifyNever(() => mockClient.closeConnection());
|
||||
});
|
||||
},
|
||||
);
|
||||
|
||||
Reference in New Issue
Block a user