Dekorieren beobachtbar

Question

Ist es OK, Observable<>, Single<>, Maybe<>, Flowable<> in RX-Java zu dekorieren?
z. wie folgt:

public final class NonEmptyStringSource extends Observable<String> { 

    private final Observable<String> source; 

    public NonEmptyStringSource(final Observable<String> source) { 
     this.source = source.filter(s -> s.length() > 0); 
    } 

    @Override 
    protected void subscribeActual(final Observer<? super String> observer) { 
     this.source.subscribe(observer); 
    } 
} 

Hat dieser Ansatz einige Tücken?
Ist es sicher in Gebrauch?

Answer 1

Im Gegensatz zu 1.x hat dieses Muster in 2.x keine Nachteile und ist fast so, wie die Standardoperatoren implementiert sind. Je nach Bedarf, können Sie eine ObservableTransformer statt implementieren:

ObservableTransformer<String, String> t = 
    upstream -> upstream.filter(s -> s.length() > 0); 

Observable.fromArray("a", "b", "", "d", "", "f") 
.compose(t) 
.subscribe(System.out::println, Throwable::printStackTrace); 

Answer 2

ich abraten würde, wie es verschleiert, was eigentlich los ist.

mit nur filter inline ist sauberer und besser lesbar:

.filter(StringUtils::isNotBlank) 

Dieses von Apache Commons-Lang kommt, aber Sie können genauso einfach Ihre eigene Implementierung rollen.