Stream<Map<String, dynamic>> get stream async* { var doc = await nextObject(); while (doc != null) { yield doc; doc = await nextObject(); } }