equal
deleted
inserted
replaced
83 * ExecutorService executor) { |
83 * ExecutorService executor) { |
84 * this.subscriber = subscriber; |
84 * this.subscriber = subscriber; |
85 * this.executor = executor; |
85 * this.executor = executor; |
86 * } |
86 * } |
87 * public synchronized void request(long n) { |
87 * public synchronized void request(long n) { |
88 * if (n != 0 && !completed) { |
88 * if (!completed) { |
89 * completed = true; |
89 * completed = true; |
90 * if (n < 0) { |
90 * if (n <= 0) { |
91 * IllegalArgumentException ex = new IllegalArgumentException(); |
91 * IllegalArgumentException ex = new IllegalArgumentException(); |
92 * executor.execute(() -> subscriber.onError(ex)); |
92 * executor.execute(() -> subscriber.onError(ex)); |
93 * } else { |
93 * } else { |
94 * future = executor.submit(() -> { |
94 * future = executor.submit(() -> { |
95 * subscriber.onNext(Boolean.TRUE); |
95 * subscriber.onNext(Boolean.TRUE); |