Formatting

snowflakedb · Dec 14, 2023 · 8fd335a · 8fd335a
1 parent 062a45d
commit 8fd335a
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/src/main/java/net/snowflake/ingest/streaming/SnowflakeStreamingIngestClient.java b/src/main/java/net/snowflake/ingest/streaming/SnowflakeStreamingIngestClient.java
@@ -6,7 +6,6 @@
 
 import java.util.List;
 import java.util.Map;
-import net.snowflake.ingest.streaming.internal.DropChannelResponse;
 
 /**
  * A class that is the starting point for using the Streaming Ingest client APIs, a single client

diff --git a/...est/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelTest.java b/...est/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelTest.java
@@ -854,7 +854,10 @@ public void testDropOnClose() throws Exception {
     Assert.assertTrue(channel.isClosed());
     Mockito.verify(client, Mockito.times(1))
         .dropChannel(
-            argThat((DropChannelRequest req) -> req.getChannelName().equals(channel.getName()) && req.getClientSequencer().equals(channel.getChannelSequencer())));
+            argThat(
+                (DropChannelRequest req) ->
+                    req.getChannelName().equals(channel.getName())
+                        && req.getClientSequencer().equals(channel.getChannelSequencer())));
   }
 
   @Test

diff --git a/...test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientTest.java b/...test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientTest.java
@@ -407,10 +407,10 @@ public void testDropChannel() throws Exception {
             .build();
     client.dropChannel(request);
     Mockito.verify(requestBuilder)
-            .generateStreamingIngestPostRequest(
-                    ArgumentMatchers.contains("channel"),
-                    ArgumentMatchers.refEq(DROP_CHANNEL_ENDPOINT),
-                    ArgumentMatchers.refEq("drop channel"));
+        .generateStreamingIngestPostRequest(
+            ArgumentMatchers.contains("channel"),
+            ArgumentMatchers.refEq(DROP_CHANNEL_ENDPOINT),
+            ArgumentMatchers.refEq("drop channel"));
   }
 
   @Test