我正在尝试在 Flutter 上使用 Cloud Firestore。到目前为止,我已经能够使用它,但我想在我的项目中包含使用 firestore 的功能的单元测试。我正在使用 Mockito 来做同样的事情,我认为它应该可以工作。
但我真的对 Dart 的 StreamMatchers 感到困惑。我无法理解错误消息。
下面是我想要实现的一些代码以及我得到的错误。
存储库.dart
import 'dart:async';
import 'package:cloud_firestore/cloud_firestore.dart';
import 'package:sunapsis_conference18/models/conference_event.dart';
Stream<List<ConferenceEvent>> getAllEvents() {
return _firestore
.collection(_collectionName)
.snapshots()
.map((QuerySnapshot snapshot) => _eventMapper(snapshot));
}
List<ConferenceEvent> _eventMapper(QuerySnapshot snapshot) {
List<ConferenceEvent> events = [];
for (int i = 0; i < snapshot.documents.length; i++) {
DocumentSnapshot documentSnapshot = snapshot.documents[i];
ConferenceEvent event =
ConferenceEvent.buildFromMap(documentSnapshot.data);
events.add(event);
}
return events;
}
它方法尝试从 firestore 集合中获取数据并返回数据对象列表流。
repository_test.dart
import 'dart:async';
import 'package:cloud_firestore/cloud_firestore.dart';
import 'package:mockito/mockito.dart';
import 'package:sunapsis_conference18/models/conference_event.dart';
import 'package:sunapsis_conference18/repository/repository.dart'; //quotation mark fix
import 'package:test/test.dart';
class MockDocumentReference extends Mock implements DocumentReference {}
class MockFirestore extends Mock implements Firestore {}
class MockCollectionReference extends Mock implements CollectionReference {}
class MockQuerySnapshot extends Mock implements QuerySnapshot {}
class MockDocumentSnapshot extends Mock implements DocumentSnapshot {}
class MockQuery extends Mock implements Query {}
main() {
group('getAllEvents() tests', () {
final Firestore mockFirestore = MockFirestore();
final CollectionReference mockCollectionReference =
MockCollectionReference();
final QuerySnapshot mockQuerySnapshot = MockQuerySnapshot();
final DocumentSnapshot mockDocumentSnapshot = MockDocumentSnapshot();
final Repository repository = Repository(mockFirestore);
final DocumentReference _mockDocumentRef = MockDocumentReference();
final Map<String, dynamic> _responseMap = {
'foo': 123,
'bar': 'Test title',
};
final ConferenceEvent _event = ConferenceEvent.buildFromMap(_responseMap);
test('returns correct stream of list of ConferenceEvent', () async {
when(mockFirestore.collection('events'))
.thenReturn(mockCollectionReference);
when(mockCollectionReference.snapshots())
.thenAnswer((_) => Stream.fromIterable([mockQuerySnapshot]));
when(mockQuerySnapshot.documents).thenReturn([mockDocumentSnapshot]);
when(mockDocumentSnapshot.data).thenReturn(_responseMap);
await expectLater(
repository.getAllEvents(),
emitsAnyOf([
[_event],
emitsDone
]));
});
});
}
我无法制定正确的流匹配器,同时也无法理解错误消息。
错误
Expected: should do one of the following:
• emit an event that [Instance of 'ConferenceEvent']
• be done
Actual: <Instance of '_MapStream<QuerySnapshot, List<ConferenceEvent>>'>
Which: emitted • [Instance of 'ConferenceEvent']
x Stream closed.
which failed all options:
• failed to emit an event that [Instance of 'ConferenceEvent'] because it emitted an event that was <Instance of 'ConferenceEvent'> instead of <Instance of 'ConferenceEvent'> at location [0]
• failed to be done
任何有助于理解错误消息的指导将不胜感激。另外,这是测试此功能的正确方法吗?