Skip to content

Commit

Permalink
Sinks.one() not fuseable for now, removing one unrelated test dependi…
Browse files Browse the repository at this point in the history
…ng on fusion
  • Loading branch information
simonbasle committed Aug 16, 2021
1 parent 73f3b73 commit 84814b7
Showing 1 changed file with 0 additions and 11 deletions.
11 changes: 0 additions & 11 deletions reactor-test/src/test/java/reactor/test/StepVerifierTests.java
Original file line number Diff line number Diff line change
Expand Up @@ -2330,17 +2330,6 @@ public void verifyLaterCanVerifyConnectableFlux_withAssertionErrors() {

@Test
public void verifyDrainOnRequestInCaseOfFusion() {
Sinks.One<Integer> processor = Sinks.one();
StepVerifier.create(processor.asMono(), 0)
.expectFusion(Fuseable.ANY)
.then(() -> processor.emitValue(1, FAIL_FAST))
.thenRequest(1)
.expectNext(1)
.verifyComplete();
}

@Test
public void verifyDrainOnRequestInCaseOfFusion2() {
ArrayList<Long> requests = new ArrayList<>();
Sinks.Many<Integer> processor = Sinks.many().unicast().onBackpressureBuffer();
StepVerifier.create(processor.asFlux().doOnRequest(requests::add), 0)
Expand Down

0 comments on commit 84814b7

Please sign in to comment.