### Question:
ReactiveFileReader { public Flux<DataBuffer> backpressuredShakespeare() { return DataBufferUtils .read( new DefaultResourceLoader().getResource("hamlet.txt"), new DefaultDataBufferFactory(), 1024 ) .log(); }  Flux<DataBuffer> backpressuredShakespeare();  }### Answer:
@Test public void readShakespeareWithBackpressureTest() { StepVerifier.create(reader.backpressuredShakespeare(), 1) .assertNext(db -> assertThat(db.capacity()).isEqualTo(1024)) .expectNoEvent(Duration.ofMillis(2000)) .thenRequest(1) .assertNext(db -> assertThat(db.capacity()).isEqualTo(1024)) .thenCancel() .verify(); }