convertStream<T> method
convert stream version.
Implementation
Stream<T?> convertStream<T>(T Function(Map<String, dynamic>) convertor) {
return readStream().map((event) {
if (event != null && event.isNotEmpty) {
return convertor(event);
}
return null;
});
}