Use the new onSubscribe().invoke variant taking a Runnable
@@ -27,7 +27,7 @@ public class MultiDisjointTest {
Multi.createFrom().items("d", "e"),
Multi.createFrom().empty(),
Multi.createFrom().items("f", "g")
- .onSubscribe().invoke(s -> subscribed.set(true)))
+ .onSubscribe().invoke(() -> subscribed.set(true)))
.onItem().<String> disjoint()
.subscribe().withSubscriber(AssertSubscriber.create(4));
assertThat(subscribed).isFalse();
@@ -96,7 +96,7 @@ public class MultiDisjointTest {
Multi.createFrom().items("d", "e"),
Multi.createFrom().failure(new IOException("boom")),
Multi.createFrom().items("f", "g")
- .onSubscribe().invoke(s -> subscribed.set(true)))
+ .onSubscribe().invoke(() -> subscribed.set(true)))
.onItem().<String> disjoint()
.subscribe().withSubscriber(AssertSubscriber.create(4));
assertThat(subscribed).isFalse();
@@ -117,7 +117,7 @@ public class MultiDisjointTest {
e.fail(new IOException("boom"));
}),
Multi.createFrom().items("g")
- .onSubscribe().invoke(s -> subscribed.set(true)))
+ .onSubscribe().invoke(() -> subscribed.set(true)))
.onItem().<String> disjoint()
.subscribe().withSubscriber(AssertSubscriber.create(4));
assertThat(subscribed).isFalse();
