RxJava Relay vs Przedmioty

Question

Próbuję zrozumieć cel tej biblioteki przez Jake Warthon: https://github.com/JakeWharton/RxRelay

Zasadniczo: Przedmiotem wyjątkiem bez możliwości wywołania onComplete lub onError. Przedmioty są bardzo szkodliwe dla stanu: po otrzymaniu onComplete lub onError przestają być przydatne do przenoszenia danych.

Wpadam na pomysł, jest to ważny przypadek użycia, ale powyższe wydaje się łatwe do osiągnięcia po prostu przy użyciu istniejących obiektów.

1. nie przesyłać errors/completions zdarzenia do tematu:

`observable.subscribe({ subject.onNext(it) }, { log error/throw exception },{ ... })` 

2. Nie wystawiać przedmiot, zrobić podpis sposób zauważalny powrót zamiast.

fun(): Observable<> { return subject }

Ja oczywiście brakuje czegoś tutaj i jestem bardzo osobliwości na temat tego, co to jest!

class MyPublishRelay<I> : Consumer<I> { 

    private val subject: Subject<I> = PublishSubject.create<I>() 

    override fun accept(intent: I) = subject.onNext(intent) 

    fun subscribe(): Disposable = subject.subscribe() 
    fun subscribe(c: Consumer<in I>): Disposable = subject.subscribe(c) 
    //.. OTHER SUBSCRIBE OVERLOADS 
} 

Answer 1

subscribe ma przeciążeń i zazwyczaj ludzie przyzwyczajają się do przeciążenia subscribe(Consumer). Następnie używają tematów i nagle wywoływany jest także onComplete. RxRelay zapisuje użytkownika, który nie myśli o różnicy między subscribe(Consumer) i subscribe(Observer).

1. Nie przekazania Uzupełnienia błędów/zdarzeń do tematu:

Rzeczywiście, ale na podstawie naszych doświadczeń z początkujących, często nie myślą o tym, a nawet wiedzieć dostępne metody do rozważenia.

2. Nie wolno wystawiać tematu, spraw, by podpis metody zwracał się do obserwowalnego.

Jeśli potrzebujesz sposobu na przesłanie przedmiotu do tematu, to nie działa. Celem jest wykorzystanie podmiotu do rozsyłania grupowego przedmiotów, czasami z innego numeru Observable. Jeśli masz pełną kontrolę nad emisjami przez Subject, powinieneś mieć przyzwoitość nie dzwoniąc pod numer onComplete i nie pozwalając, aby cokolwiek innego to zrobiło.