convertStreamForce<T> method

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

Implementation

Stream<T> convertStreamForce<T>(T Function(Map<String, dynamic>) convertor) {
  return readStream().map((event) {
    if (event != null && event.isNotEmpty) {
      return convertor(event);
    }
    throw Exception('event is null');
  });
}