RxJava filtra y emite otros elementos

¿Es posible filtrar y continuar emitiendo itens como a continuación?


Mi código que llama al suscriptor 2 veces:

Observable<Map.Entry<String, ArrayList<MockOverview>>> requestEntries =
        this.requestView.request(request)
        .map(HashMap::entrySet)
        .flatMapIterable(entries -> entries);

requestEntries.filter(entry -> entry.getKey().equals("featured"))
        .map((Func1<Map.Entry<String, ArrayList<MockOverview>>, List<MockOverview>>) Map.Entry::getValue)
        .subscribe(mockOverviews -> {
            Log.i("subscrive", "featured");
        });

requestEntries.filter(entry -> entry.getKey().equals("done"))
        .map((Func1<Map.Entry<String, ArrayList<MockOverview>>, List<MockOverview>>) Map.Entry::getValue)
        .subscribe(mockOverviews -> {
            Log.i("subscrive", "featured");
        });

Lo que quiero:

 requestEntries.filter(entry -> entry.getKey().equals("featured"))
        .map((Func1<Map.Entry<String, ArrayList<MockOverview>>, List<MockOverview>>) Map.Entry::getValue)
        .subscribe(mockOverviews -> {

        })
        .filter(entry -> entry.getKey().equals("done"))
        .map((Func1<Map.Entry<String, ArrayList<MockOverview>>, List<MockOverview>>) Map.Entry::getValue)
        .subscribe(mockOverviews -> {

        });
Respuesta 1

Puedes usar doOnNexten lugar del primerosubscribe()

 requestEntry.filter(v -> ...)
 .map(v -> ...)
 .doOnNext(v -> ...)
 .filter(v -> ...)
 .map(v -> ...)
 .subscribe(...)

o usar publish(Func1):

 requestEntry.filter(v -> ...)
 .map(v -> ...)
 .publish(o -> {
     o.subscribe(...);
     return o;
 })
 .filter(v -> ...)
 .map(v -> ...)
 .subscribe(...)
Respuesta: 2

Tengo un flujo de palabras y me gustaría ordenarlas según la aparición de los mismos elementos (= palabras). por ejemplo: {hola, mundo, hola} al Mapa <Cadena, Lista <String>> hola, {hola, ...

¿Hay alguna biblioteca de red C ++ similar a Netty de JBoss? Necesito una arquitectura donde pueda agregar controladores de protocolo a una lista y procesar paquetes de red como objetos.

He estado jugando con esta expresión regular en Java durante años y no puedo hacer que funcione: (?: ^ |) (?: the | and | at | in | or | on | off | all | next | under | sobre | siguiente) (?: | $) Lo siguiente: pattern.matcher ("el gato en el sombrero") ...

Estoy usando la validación basada en resorte en combinación con el validador de hibernación habilitado por lo siguiente en el contexto de mi aplicación: <bean id = "entityManagerFactory" class = "org.springframework.orm.jpa ...