Firebase возвращает обещание снэпшота

Я использую firebase / firestore и ищу способ вернуть обещание снимка.

onlineUsers(){
     // i want to return onSnapshot
    return this.status_database_ref.where('state','==','online').onSnapshot();
}

в другом файле я сделал

  componentDidMount(){
    // this.unsubscribe = this.ref.where('state','==','online').onSnapshot(this.onCollectionUpdate) 
    firebaseService.onlineUsers().then(e=>{
        console.info(e)
    })
}

Я получаю ошибки

Error: Query.onSnapshot failed: Called with invalid arguments.

TypeError: _firebaseService2.default.unsubscribe is not a function

если я сделаю так

onlineUsers(){
   return  this.status_database_ref.where('state','==','online').onSnapshot((querySnapshot)=>{
        return querySnapshot
    }) 
}

я получил

TypeError: _firebaseService2.default.onlineUsers(...).then is not a function

Кроме того, когда я так делаю

   this.unsubscribe = firebaseService.onlineUsers().then((querySnapshot)=>{
        console.info(querySnapshot.size)
        this.setState({count:querySnapshot.size})
    })

// другой файл

 onlineUsers(callback) {
    return this.status_database_ref.where('state', '==', 'online').get()
}

он не слушает изменения в firebase, это означает, что если я изменю в firebase, он не обновит или не изменит размер ..

---- функция firestore --- Я попытался сделать функцию firestore, которая запускается каждый раз, когда узел UserStatus обновляется, но это занимает несколько секунд и для меня это медленно.

module.exports.onUserStatusChanged = functions.database
.ref('/UserStatus/{uid}').onUpdate((change, context) => {
    // Get the data written to Realtime Database
    const eventStatus = change.after.val();

    // Then use other event data to create a reference to the
    // corresponding Firestore document.
    const userStatusFirestoreRef = firestore.doc(`UserStatus/${context.params.uid}`);


    // It is likely that the Realtime Database change that triggered
    // this event has already been overwritten by a fast change in
    // online / offline status, so we'll re-read the current data
    // and compare the timestamps.
    return change.after.ref.once("value").then((statusSnapshot) => {
        return statusSnapshot.val();
    }).then((status) => {
        console.info(status, eventStatus);
        // If the current timestamp for this data is newer than
        // the data that triggered this event, we exit this function.
        if (status.last_changed > eventStatus.last_changed) return status;

        // Otherwise, we convert the last_changed field to a Date
        eventStatus.last_changed = new Date(eventStatus.last_changed);

        // ... and write it to Firestore.
        //return userStatusFirestoreRef.set(eventStatus);
        return userStatusFirestoreRef.update(eventStatus);
    });
});

функция для подсчета и обновления количества онлайн-пользователей

module.exports.countOnlineUsers = functions.firestore.document('/UserStatus/{uid}').onWrite((change, context) => {

    const userOnlineCounterRef = firestore.doc('Counters/onlineUsersCounter');

    const docRef = firestore.collection('UserStatus').where('state', '==', 'online').get().then(e => {
        let count = e.size;
        return userOnlineCounterRef.update({ count })
    })
})