### Question:
VertxServerHttpRequest extends AbstractServerHttpRequest { @Override public Flux<DataBuffer> getBody() { return bodyFlux; } VertxServerHttpRequest(RoutingContext context, BufferConverter bufferConverter); @SuppressWarnings("unchecked") @Override T getNativeRequest(); @Override String getMethodValue(); @Override Flux<DataBuffer> getBody(); @Override InetSocketAddress getRemoteAddress();  }### Answer:
@Test public void shouldGetBody() { Buffer firstBuffer = Buffer.buffer("chunk 1"); Buffer secondBuffer = Buffer.buffer("chunk 2"); given(mockHttpServerRequest.exceptionHandler(any())).willReturn(mockHttpServerRequest); given(mockHttpServerRequest.handler(any())).will(invocation -> { Handler<Buffer> handler = invocation.getArgument(0); handler.handle(firstBuffer); handler.handle(secondBuffer); return mockHttpServerRequest; }); given(mockHttpServerRequest.endHandler(any())).will(invocation -> { Handler<Void> handler = invocation.getArgument(0); handler.handle(null); return mockHttpServerRequest; }); StepVerifier.create(vertxServerHttpRequest.getBody()) .expectNext(bufferConverter.toDataBuffer(firstBuffer)) .expectNext(bufferConverter.toDataBuffer(secondBuffer)) .verifyComplete(); }