бую базу данных firestore на Android.

Это мой код, который вставляет документ:

public Observable<Post> createPost(final Post post){


        return Observable.create(new Observable.OnSubscribe<Post>() {
            @Override
            public void call(final Subscriber<? super Post> subscriber) {

                try{

                    DocumentReference documentReference = getCollection().document();

                    post.setId(documentReference.getId());
                    documentReference.set(post).addOnSuccessListener(new OnSuccessListener<Void>() {
                        @Override
                        public void onSuccess(Void aVoid) {

                            subscriber.onNext(post);
                            subscriber.onCompleted();

                        }
                    }).addOnFailureListener(new OnFailureListener() {
                        @Override
                        public void onFailure(@NonNull Exception e) {
                            subscriber.onError(e);
                            subscriber.onCompleted();
                        }
                    });


                }catch (Exception ex){

                    subscriber.onError(ex);

                    Log.e(LOG_TAG, ex.getMessage(), ex);

                }

            }
        });


    }

Документ вставляется в базу данных, но ни обратные вызовы onSuccess, ни onFailure не вызываются.

Обновление 1

1) Проблема не постоянная, иногда она работает, иногда обратные вызовы вызываются через час, иногда через 3 часа и т. Д.

2) Это происходит, когда нет подключения к интернету.

Обновление 2

1) О проблеме сообщилиВот и это закрыто. Я не уверен, как гарантировать правильность данных, созданных в автономном режиме.