Ist es möglich, synchron laden von Daten aus FB?

Auf einer regulären JVM, Sie würde dies tun, mit regulären Java-Synchronisation primitiven.

Beispiel:

//create a java.util.concurrent.Semaphore with 0 initial permits
final Semaphore semaphore = new Semaphore(0);

//attach a value listener to a Firebase reference
ref.addValueEventListener(new ValueEventListener() {
    //onDataChange will execute when the current value loaded and whenever it changes
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        //TODO: do whatever you need to do with the dataSnapshot

        //tell the caller that we're done
        semaphore.release();
    }

    @Override
    public void onCancelled(FirebaseError firebaseError) {

    }
});

//wait until the onDataChange callback has released the semaphore
semaphore.acquire();

//send our response message
ref.push().setValue("Oh really? Here is what I think of that");

Aber das funktioniert nicht auf Android. Und das ist eine Gute Sache, denn es ist eine schlechte Idee, diese Art von blockieren Ansatz, was auf die Benutzeroberfläche. Der einzige Grund, ich hatte diesen code rumliegen, weil ich brauchte, in einem unit-test.

In real-user-facing-code, den Sie gehen sollten, für einen event-driven Ansatz. Also statt "warten Sie, bis die Daten kommen und und dann send my message", würde ich "wenn die Daten kommt, sendet meine Botschaft":

//attach a value listener to a Firebase reference
ref.addValueEventListener(new ValueEventListener() {
    //onDataChange will execute when the current value loaded and whenever it changes
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        //TODO: do whatever you need to do with the dataSnapshot

        //send our response message
        ref.push().setValue("Oh really? Here is what I think of that!");
    }

    @Override
    public void onCancelled(FirebaseError firebaseError) {

    }
});

Das Ergebnis ist genau das gleiche, aber dieser code nicht erforderlich, Synchronisation und nicht blockieren auf dem Android.

Ich kam mit einem anderen Weg, der das abrufen von Daten synchron.
Voraussetzung ist nicht auf dem UI-Thread.

final TaskCompletionSource<List<Objects>> tcs = new TaskCompletionSource<>();

firebaseDatabase.getReference().child("objects").addListenerForSingleValueEvent(new ValueEventListener() {

            @Override
            public void onDataChange(DataSnapshot dataSnapshot) {
                Mapper<DataSnapshot, List<Object>> mapper = new SnapshotToObjects();
                tcs.setResult(mapper.map(dataSnapshot));
            }

            @Override
            public void onCancelled(DatabaseError databaseError) { 
                tcs.setException(databaseError.toException());
            }

        });

Task<List<Object>> t = tcs.getTask();

try {
    Tasks.await(t);
} catch (ExecutionException | InterruptedException e) {
    t = Tasks.forException(e);
}

if(t.isSuccessful()) {
    List<Object> result = t.getResult();
}

Getestet habe ich meine Lösung und es ist in Ordnung, aber bitte beweisen mich nicht falsch!

Wenn jemand auch darüber nachzudenken, wie zu verwenden Kotlin ist coroutine, die Sie verwenden können kotlinx-Coroutinen-play-services.

Hinzufügen, um Ihre app build.gradle Datei:

implementation "org.jetbrains.kotlinx:kotlinx-coroutines-play-services:1.1.1"

Dann einfach:

suspend fun signIn(email: String, password: String) {
    try {
        val auth: FirebaseAuth = FirebaseAuth.getInstance()
        auth.signInWithEmailAndPassword(email, password).await()
    } catch (e: FirebaseAuthException) {
        println("${e.errorCode}: ${e.message}")
    }
}