Cómo Observable es creado en retrofit sin llamarlo de programador?

Estoy trabajando en rx-java y de readaptación, y tengo algunas consultas relacionadas con ella.Yo no soy capaz de entender que cuando llamamos a continuación el código, a continuación, cómo Observable(Observable) es creada ? De acuerdo, a mi entender, debería ser llamado sólo durante el tiempo de programación y de suscripción.

CryptocurrencyService cryptocurrencyService = retrofit.create(CryptocurrencyService.class);

Observable<Crypto> cryptoObservable = cryptocurrencyService.getCoinData("btc");
0
2019-09-17 16:14:34
fuente
1 respuestas

Con acks=all y si el factor de replicación del tema es > 1, es todavía posible perder mensajes reconocidos pero muy raro.

Por ejemplo, si usted tiene 3 réplicas (y todos están en sincronía), con acks=all, usted necesita para perder todos los 3 corredores, al mismo tiempo, antes de que ninguno de ellos tenía el tiempo para hacer el real de escritura en el disco. Con acks=all, el reconocimiento se envía una vez que todos en la sincronización de réplicas han recibido el mensaje, puede asegurarse de que este número se mantiene alta con min.insync.replicas=2 por ejemplo.

Usted puede reducir la posibilidad de este escenario aún más si se utiliza el bastidor de conciencia de la función (y, obviamente, los corredores están físicamente en diferentes estantes, o mejor aún, centros de datos).

Para resumir, el uso de todas estas opciones, usted puede reducir la probabilidad de pérdida de datos suficiente, de manera que es poco probable que ocurra nunca.

+0
2019-09-17 19:43:28

Vea otras preguntas sobre etiquetas