typedef StreamCondition = MapEntry<Stream? Function(Map<StreamNode, Stream>), Future<dynamic> Function(Stream?)>;