L20 rxJava

This commit is contained in:
sergey
2023-02-09 23:33:14 +03:00
parent 39eef6df5e
commit 450f033b76
@@ -24,7 +24,7 @@ public class PublisherExample {
Thread.sleep(5000);
logger.info("Second subscribed");
var disposable2 = ob.subscribe(item -> logger.info("item: {}", item));
var disposable2 = ob.subscribe(item -> logger.info("item second: {}", item));
logger.info("disposable2.isDisposed():{}", disposable2.isDisposed());