Skip to content

Commit

Permalink
Review issues
Browse files Browse the repository at this point in the history
  • Loading branch information
danielkec committed Jun 7, 2023
1 parent 72eec08 commit 0f5adda
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -452,7 +452,7 @@ static BufferData[] split(BufferData bufferData, int size) {
BufferData[] result = new BufferData[allFrames];

for (int i = 0; i < allFrames; i++) {
boolean lastFrame = allFrames == i + 1;
boolean lastFrame = (allFrames == i + 1);
byte[] frag = new byte[lastFrame ? (lastFragmentSize != 0 ? lastFragmentSize : size) : size];
bufferData.read(frag);
result[i] = BufferData.create(frag);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ static void beforeAll() throws ExecutionException, InterruptedException, Timeout
default -> res.setStatusCode(404).end();
}
})
.listen(8080)
.listen(0)
.toCompletionStage()
.toCompletableFuture()
.get(TIMEOUT.toMillis(), MILLISECONDS);
Expand Down Expand Up @@ -137,7 +137,6 @@ void trailerHeader() {

@Test
void continuationInbound() {
System.out.println("http://localhost:" + port + "/");
try (Http2ClientResponse res = WebClient.builder(Http2.PROTOCOL)
.baseUri("http://localhost:" + port + "/")
.build()
Expand All @@ -158,7 +157,6 @@ void continuationInbound() {

@Test
void continuationOutbound() {
System.out.println("http://localhost:" + port + "/");
Set<String> expected = new HashSet<>(500);
try (Http2ClientResponse res = WebClient.builder(Http2.PROTOCOL)
.baseUri("http://localhost:" + port + "/")
Expand All @@ -181,7 +179,6 @@ void continuationOutbound() {

@Test
void continuationOutboundPost() {
System.out.println("http://localhost:" + port + "/");
Set<String> expected = new HashSet<>(500);
try (Http2ClientResponse res = WebClient.builder(Http2.PROTOCOL)
.baseUri("http://localhost:" + port + "/")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ public class HeadersTest {

@SetUpServer
static void setUpServer(WebServer.Builder serverBuilder) {
serverBuilder.port(8080)
serverBuilder.port(-1)
// HTTP/2 prior knowledge config
.addConnectionProvider(Http2ConnectionProvider.builder()
.http2Config(Http2ConfigDefault.builder()
Expand Down

0 comments on commit 0f5adda

Please sign in to comment.