演算子 SkipUntil を探していますが、期待どおりに機能していないようです。これが私のコードです
@Test
public void testSkiUitil() throws InterruptedException {
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
Observable observable2 = Observable.just(1);
Subscription subscription = Observable.from(numbers)
.skipUntil(observable2)
.subscribe(System.out::println);
Thread.sleep(3000);
observable2.subscribe();
new TestSubscriber((Observer) subscription).awaitTerminalEvent(5, TimeUnit.SECONDS);
}
observable2 にはサブスクライブがないため、演算子 skipUntil を使用して最初のオブザーバブルがすべてのアイテムをスキップする必要があるアイテムを発行していないことを証明しようとしていました。しかし、まだ5つのアイテムすべてを放出しています。
理由は?
ドクターは言います。
Returns an Observable that skips items emitted by the source Observable until a second Observable emits