Comment utiliser RxJava combineLatest opérateur avec plus de 9 observables

Je suis en utilisant RxJava et je veux combiner les 12 différents observables à l'aide de l'opérateur combineLatest.

J'ai vu un prototype de fonction qui prend une liste des observables et une mise en œuvre de FuncN mais je ne suis pas sûr de la façon de le faire, je vais avoir de la difficulté à la mise en œuvre de la call méthode.

Quelqu'un peut-il me montrer un exemple?

S'il vous plaît, format de votre code et de fonctions à l'aide de ``

InformationsquelleAutor user3762200 | 2016-08-07

java rx-java

Il y a un combineLatest qui prend un List des observables. Voici un exemple sur la façon de l'utiliser:

List<Observable<?>> list = Arrays.asList(Observable.just(1), Observable.just("2"));
Observable.combineLatest(list, new FuncN<String>() {
    @Override
    public String call(Object... args) {
        String concat = "";
        for (Object value : args) {
            if (value instanceof Integer) {
                concat += (Integer) value;
            } else if (value instanceof String) {
                concat += (String) value;
            }
        }
        return concat;
    }
});

Comment dois-je faire si j'ai des différents observables types? (eg. Observables<A>, Obsevable<B>, etc)
les valeurs à l'intérieur de args aura le même ordre que dans le list. Vous pouvez compter sur cette commande ou vérifier pour chaque type de la valeur. selon votre cas d'utilisation. J'ai édité ma réponse.
Merci, cela m'a vraiment aidé
Comment est la FuncN<String>() défini? Je n'arrive pas à se prévaloir de cette.

InformationsquelleAutor Egor Neliuba

Yo étendre sur cette réponse, je l'utilise pour lire plusieurs caractéristiques à la fois, il peut être fait comme suit:

connectionObservable
                .flatMap((Func1<RxBleConnection, Observable<?>>) rxBleConnection -> {
                    List<Observable<?>> list1 = Arrays.asList(
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...),
                            rxBleConnection.readCharacteristic(UUID...));
                    return Observable.combineLatest(list1, args -> {
                       Object o =  doSomethingWithResults(args);
                        return o;
                    });
                })
                .observeOn(AndroidSchedulers.mainThread())
                .doOnUnsubscribe(this::clearConnectionSubscription)
                .subscribe(retVal -> {
                    Log.d(TAG, "result:" + retVal.toString());
                    Log.w(TAG, "SUCCESS");
                    triggerDisconnect();

                }, MyActivity.this::onReadFailure);
    }

Commentaires si vous avez des suggestions sur la façon d'améliorer ce processus.

Ce qui se passe lorsque l'un de ces caractéristiques jeter un onError?
Il va à onReadFailure, dans mon cas, j'ai envie de jeter de l'ensemble de la lecture si l'on omet de sorte qu'il fonctionne pour moi.

InformationsquelleAutor TacoEater

RxKotlin prend en charge jusqu'à 9 opertators dans les paramètres dans combineLatest() la méthode, mais l'utilisation de plus de 9 paramètres
moyens pour passer illimité dynamique personnalisé objet arraylist vous pouvez l'utiliser comme ci-dessous:

D'abord, Permettez-moi de vous donner exemple simple avec seulement deux paramètres avec
les types de données personnalisés

val name = Observable.just("MyName")
val age = Observable.just(25)
Observables.combineLatest(name, age) { n, a -> "$n - age:${a}" }
                .subscribe({
                    Log.d("combineLatest", "onNext - ${it}")
                })

Maintenant, si je veux passer plusieurs paramètres, en combineLatest? Alors
votre réponse est ci-dessous: (j'ai utilisé les types de données personnalisés, de sorte que quelqu'un
personnalisé problème peut également être résolu ici)

val myList = arrayOf(Observable.just("MyName"),
                Observable.just(2),
                Observable.just(3.55),
                Observable.just("My Another String"),
                Observable.just(5),
                Observable.just(6),
                Observable.just(7),
                Observable.just(8),
                Observable.just(9),
                Observable.just(10),
                Observable.just(11),
                Observable.just(12),
                Observable.just(13),
                Observable.just(14),
                Observable.just(15))

Observable.combineLatest(myList, {
    val a = it[0] as String
    val b = it[1] as Int
    val c = it[2] as Float
    val d = it[3] as String
    val e = it[4] as Int
    val f = it[5] as Int
    val g = it[6] as Int
    val h = it[7] as Int
    val i = it[8] as Int
    val j = it[9] as Int
    val k = it[10] as Int
    val l = it[11] as Int
    val m = it[12] as Int
    "$a - age:${b}" })
        .subscribe({
            Log.d("combineLatest", "onNext - ${it}")
        })

InformationsquelleAutor android

0

de code ci-dessus. remplacer chaque ligne
```
rxBleConnection.readCharacteristic(UUID...),
```
avec
```
rxBleConnection.readCharacteristic(UUID...).onErrorResumeNext { bytes -> Observable.just(new byte[0])) },
```
essentiellement, vous êtes de retour d'un vide tableau d'octets si une caractéristique n'est pas trouvé. code continuera
- Ce serait mieux adapté comme un commentaire sur la réponse plutôt que d'une nouvelle réponse car il ne répond pas à la question.
- malheureusement je n'ai pas assez de "réputation" ajouter un commentaire
InformationsquelleAutor DarthHater

Vous devez vous connecter pour publier un commentaire.