From 85083af7e9d563fa257665957693d3800ea81c07 Mon Sep 17 00:00:00 2001 From: Andriy Redko Date: Tue, 15 Oct 2024 21:04:57 -0400 Subject: [PATCH] Address code review comments Signed-off-by: Andriy Redko --- .../java/org/opensearch/rest/ReactorNetty4StreamingIT.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingIT.java b/plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingIT.java index 35515a8d95d67..e022dfedb788d 100644 --- a/plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingIT.java +++ b/plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingIT.java @@ -308,7 +308,6 @@ public void testStreamingLargeDocument() throws IOException { ) ); - final Duration delay = Duration.ofMillis(1); final StreamingRequest streamingRequest = new StreamingRequest<>( "POST", "/_bulk/stream", @@ -335,7 +334,6 @@ public void testStreamingLargeDocumentThatExceedsChunkSize() throws IOException ) ); - final Duration delay = Duration.ofMillis(1); final StreamingRequest streamingRequest = new StreamingRequest<>( "POST", "/_bulk/stream",