Есть ли у субъекта / наблюдателя RxJ возможность "сдвинуть" новую подписку вместо "push" one`? Другими словами, разрешить обрабатывать определенные новые подписки раньше старых?
например:
subject = Subject();
a = subject.subscribe();
b = subject.subscribe();
bx = subject.subscribe(); // <= let it handle first.
c = subject.subscribe();
subject.next()
// => usually: handles a, b, bx, c
// => I want: handles bx, a, b, c
Причина этого заключается в функции повторной проверки, которую необходимо вызывать до вызова обработки по умолчанию, котораявозможно, добавляет еще одну подписку, например bx
При таком обычном порядке обработки я получил вторую ненужную обработку bx. Трудно объяснить это подробно, поэтому я надеюсь, что это так понятно.