Как управлять потоком FireStore с RXDART

Question

Я хочу изменить потоковые данные, полученные из Firestore, добавив новое свойство и изменив существующие.

Я пытался сделать это с помощью RXdart

PublishSubject<QuerySnapshot> _fixtureStreamController = PublishSubject<QuerySnapshot>();
  Observable<QuerySnapshot> get counterObservable => _fixtureStreamController.stream;
Firestore.instance.collection("places").snapshots().listen((data) {
      data.documents.map((d) => {
         d['name'].toUpperCase();
         d['newProperty'] = 'new data';
      });
      _fixtureStreamController.add(data);
    }
);

Я ожидаю получить новый поток, который я могу использовать в StreamBuilder