convertStream<T> method

Stream<T?> convertStream<T>(
  1. T convertor(
    1. Map<String, dynamic>
    )
)

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;
  });
}