RX Firebase

repo.requestNotes()
    .flatMap(snapshot -> Observable.from(snapshot.getChildren())
                            .map(Note::deserialiseNote)
                            .toList())
    .subscribe(list -> {
        notesView.updateAdapter(list);
        Log.d("RX", "Sending new data");
});