Блог

Допустим, мы используем Firebase ChildEventListener, который можно использовать в качестве нескольких источников данных (его функций), и я оборачиваю его потоковым или наблюдаемым. Я хочу, чтобы в каждом источнике излучатель передавал данные в другой конвейер, потому что в каждом случае данные могут быть изменены, я хочу обрабатывать их по — разному, то есть разделять излучение на несколько разных потоков в зависимости от типа события.

Как это можно сделать на Java?

   public void newUsers() {
    DatabaseReference ref = database.getReference().child("Users");
    Flowable.create(emitter -> {
        ref.addChildEventListener(new ChildEventListener() {
            @Override
            public void onChildAdded(@NonNull DataSnapshot dataSnapshot, @Nullable String s) {
                User userData = dataSnapshot.getValue(User.class);
                emitter.onNext(userData);
            }

            @Override
            public void onChildChanged(@NonNull DataSnapshot dataSnapshot, @Nullable String s) {
             User userData = dataSnapshot.getValue(User.class);
                emitter.onNext(userData);
            }

            @Override
            public void onChildRemoved(@NonNull DataSnapshot dataSnapshot) {
             User userData = dataSnapshot.getValue(User.class);
                emitter.onNext(userData);
            }

            @Override
            public void onChildMoved(@NonNull DataSnapshot dataSnapshot, @Nullable String s) {
                emitter.onNext(userData);
            }

            @Override
            public void onCancelled(@NonNull DatabaseError databaseError) {
             User userData = dataSnapshot.getValue(User.class);
                emitter.onNext(userData);
            }
        });
    }
}
 

Таким образом, чтобы иметь несколько потоков, у нас не может быть одного Flowable . Я не знаю, является ли текучесть на самом деле требованием, поэтому я просто изложу свою идею, вы можете исправить ее и адаптировать к своим потребностям.

    BehaviourSubject childAddedStream;
   BehaviourSubject childChangedStream;
   BehaviourSubject childRemovedStream;
   BehaviourSubject childMovedStream;
   BehaviourSubject cancelledStream;

  public void newUsers() {
    DatabaseReference ref = database.getReference().child("Users");
    
    ref.addChildEventListener(new ChildEventListener() {
            @Override
            public void onChildAdded(@NonNull DataSnapshot dataSnapshot, @Nullable String s) {
                User userData = dataSnapshot.getValue(User.class);
                childAddedStream.onNext(userData);
            }

            @Override
            public void onChildChanged(@NonNull DataSnapshot dataSnapshot, @Nullable String s) {
             User userData = dataSnapshot.getValue(User.class);
             childChangedStream.onNext(userData);
            }

            @Override
            public void onChildRemoved(@NonNull DataSnapshot dataSnapshot) {
             User userData = dataSnapshot.getValue(User.class);
             childRemovedStream.onNext(userData);
            }

            @Override
            public void onChildMoved(@NonNull DataSnapshot dataSnapshot, @Nullable String s) {
            childMovedStream.onNext(userData);
            }

            @Override
            public void onCancelled(@NonNull DatabaseError databaseError) {
             User userData = dataSnapshot.getValue(User.class);
             cancelledStream.onNext(userData);
            }
        });
    }
}
 

что-то подобное было бы моей отправной точкой.

Идея заключается в том, чтобы этот класс инициализировал разные субъекты для каждого обратного вызова, регистрировал обратный вызов в базе данных FirebaseDatabase, когда он был создан, и перенаправлял отдельные обратные вызовы в разные потоки (субъекты, не стесняйтесь использовать более релевантную Тему, которая, если хотите, подчиняется объекту) — тогда всем, кому нужно слушать, просто прослушивает соответствующий поток вместо одного потока, который просто действует как мост между обратным вызовом и реактивным миром.