Project Reactor: About Scannable interface
Simple to say, reactor.core.Scannable interface is for accessing internal attributes of flux instance for debugging purpose. Following is an example Flux<Integer> f1 = Flux.just(1, 2, 3, 4); Scannable s1 = Scannable.from(f1); LOGGER.info(“BUFFERED={}, RUN_STYLE={}”, s1.scan(Scannable.Attr.BUFFERED), s1.scan(Scannable.Attr.RUN_STYLE)); Flux<Integer> f2 = f1.map(x -> x * 2); Scannable s2 = Scannable.from(f2); LOGGER.info(“RUN_STYLE={}, PREFETCH={}, PARENT={}”, s2.scan(Scannable.Attr.RUN_STYLE), s2.scan(Scannable.Attr.PREFETCH), s2.scan(Scannable.Attr.PARENT)); The output…
:format(jpeg):quality(80)/wp-content/uploads/2024/04/cum-se-salveaza-dinamo-ioan-andone-giani-kirita-dezbatere-incinsa-dinamo-poli-iasi.jpg "Kopic ar putea implementa modelul Prandelli pentru a salva Dinamo de la retrogradare! „Eu asta nu înțelegeam” / „Nu mai avem identitate”")
:format(jpeg):quality(80)/wp-content/uploads/2024/04/betano-betbuilder-1304.jpg "(P) Spectacol la înălțime în NBA. Se joacă meciurile care hotărăsc ordinea finală după sezonul regular")