# | Line 65 | Line 65 | import java.util.stream.Stream; | |
---|---|---|
65 | * completed = true; | |
66 | * if (n < 0) { | |
67 | * IllegalStateException ex = new IllegalStateException(); | |
68 | < | * executor.submit(() -> subscriber.onError(ex)); |
68 | > | * executor.execute(() -> subscriber.onError(ex)); |
69 | * } | |
70 | * else { | |
71 | * future = executor.submit(() -> { |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |