Skip to content

Commit

Permalink
Update test case
Browse files Browse the repository at this point in the history
  • Loading branch information
dilanSachi committed Jan 30, 2024
1 parent f005c86 commit 9bcc695
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@
import java.util.concurrent.TimeUnit;

import static io.ballerina.stdlib.http.transport.contract.Constants
.REMOTE_SERVER_SENT_GOAWAY_BEFORE_INITIATING_INBOUND_RESPONSE;
.REMOTE_SERVER_SENT_GOAWAY_WHILE_READING_INBOUND_RESPONSE_HEADERS;
import static io.ballerina.stdlib.http.transport.http2.frameleveltests.FrameLevelTestUtils.END_SLEEP_TIME;
import static io.ballerina.stdlib.http.transport.http2.frameleveltests.FrameLevelTestUtils.GO_AWAY_FRAME_MAX_STREAM_01;
import static io.ballerina.stdlib.http.transport.http2.frameleveltests.FrameLevelTestUtils.SETTINGS_FRAME;
Expand Down Expand Up @@ -74,7 +74,7 @@ private void testGoAwayFor100ContinueForASingleStream() {
responseFuture.setHttpConnectorListener(requestListener);
latch.await(TestUtil.HTTP2_RESPONSE_TIME_OUT, TimeUnit.SECONDS);
assertEquals(getErrorResponseMessage(requestListener),
REMOTE_SERVER_SENT_GOAWAY_BEFORE_INITIATING_INBOUND_RESPONSE);
REMOTE_SERVER_SENT_GOAWAY_WHILE_READING_INBOUND_RESPONSE_HEADERS);
} catch (InterruptedException e) {
LOGGER.error("Interrupted exception occurred");
}
Expand Down Expand Up @@ -104,7 +104,6 @@ private void sendGoAwayForASingleStream(OutputStream outputStream) throws IOExce
outputStream.write(SETTINGS_FRAME_WITH_ACK);
Thread.sleep(SLEEP_TIME);
outputStream.write(GO_AWAY_FRAME_MAX_STREAM_01);
Thread.sleep(SLEEP_TIME);
Thread.sleep(END_SLEEP_TIME);
}

Expand Down

0 comments on commit 9bcc695

Please sign in to comment.