Tengo una transmisión Rx que es una fuente de cambio saliente de un componente en particular.

Ocasionalmente quiero poder ingresar unpor lotes en la secuencia para que los elementos pasen aEn el siguiente se acumulan y se transmiten solo cuando se sale del modo por lotes.

Normalmente pasaré elementos individuales a través de la secuencia:

stream.onNext(1); 
stream.onNext(2);

Hay una asignación de 1 a 1 entre los elementos pasados aEn el siguiente y los artículos recibidos en elsuscribir, por lo que el fragmento anterior genera dos llamadas asuscribir con los valores 1 y 2.

lospor lotes Estoy buscando podría funcionar algo como esto:

stream.enterBatchMode();
stream.onNext(1);
stream.onNext(2);
stream.exitBatchMode();

En este caso quierosuscribir solo se invocará una vez con la única matriz concatenada [1, 2].

Solo para reiterar, necesito el modo por lotes solo a veces, otras veces paso los elementos no concatenados.

¿Cómo puedo lograr este comportamiento con Rx?

NOTA: Anteriormente estaba pasando matrices a través deEn el siguiente aunque esto es principalmente para que el tipo permanezca igual cuando está en modo individual y cuando está en modo por lotes.

P.ej:

stream.onNext([1, 2, 3]); 
stream.onNext([4, 5, 6]);

Suscribirse recibe [1, 2, 3] y luego [4, 5, 6], pero cuando está en modo por lotes, suscribirse recibe los resultados concatenados [1, 2, 3, 4, 5, 6].

Entonces, cuando lo miras de esta manera, es más comono concatenado yconcatenados modos (en oposición aindividual ypor lotes) Pero creo que el problema es muy similar.