*: fix fmt (#217)

Author: alissa-tung

client/build.gradle.kts

@@ -8,7 +8,7 @@ plugins {
     id("signing")
 
     kotlin("jvm") version "1.6.10"
-    id("com.diffplug.spotless") version "6.2.0"
+    id("com.diffplug.spotless") version "6.20.0"
 
     id("me.champeau.jmh") version "0.6.7"
 }
@@ -147,17 +147,25 @@ publishing {
             // def releasesRepoUrl = layout.buildDirectory.dir('repos/releases')
             // def snapshotsRepoUrl = layout.buildDirectory.dir('repos/snapshots')
             url = uri(
-                if (version.toString().endsWith("SNAPSHOT")) snapshotsRepoUrl else releasesRepoUrl
+                if (version.toString().endsWith("SNAPSHOT")) snapshotsRepoUrl else releasesRepoUrl,
             )
             credentials {
                 username =
-                    if (project.hasProperty("ossrhUsername")) project.property("ossrhUsername") as String? else System.getenv(
-                        "OSSRH_USERNAME"
-                    )
+                    if (project.hasProperty("ossrhUsername")) {
+                        project.property("ossrhUsername") as String?
+                    } else {
+                        System.getenv(
+                            "OSSRH_USERNAME",
+                        )
+                    }
                 password =
-                    if (project.hasProperty("ossrhPassword")) project.property("ossrhPassword") as String? else System.getenv(
-                        "OSSRH_TOKEN"
-                    )
+                    if (project.hasProperty("ossrhPassword")) {
+                        project.property("ossrhPassword") as String?
+                    } else {
+                        System.getenv(
+                            "OSSRH_TOKEN",
+                        )
+                    }
             }
         }
     }
@@ -194,12 +202,12 @@ tasks.withType<Jar> {
 
 spotless {
     java {
-        target("client/src/*/java/**/*.java")
+        target("**/*.java")
         googleJavaFormat()
     }
 
     kotlin {
-        target("client/src/*/kotlin/**/*.kt")
+        target("**/*.kt")
         ktlint()
     }
 

client/src/main/java/io/hstream/BatchAckResponder.java

@@ -1,5 +1,5 @@
 package io.hstream;
 
 public interface BatchAckResponder {
-    void ackAll();
+  void ackAll();
 }

client/src/main/java/io/hstream/ConsumerBuilder.java

@@ -1,8 +1,5 @@
 package io.hstream;
 
-import java.util.List;
-import java.util.function.BiConsumer;
-
 /** A builder for {@link Consumer}s. */
 public interface ConsumerBuilder {
 

client/src/main/java/io/hstream/FlowControlSetting.java

@@ -1,6 +1,6 @@
 package io.hstream;
 
-import static com.google.common.base.Preconditions.*;
+import static com.google.common.base.Preconditions.checkState;
 
 public class FlowControlSetting {
 

client/src/main/java/io/hstream/HStreamClient.java

@@ -6,25 +6,35 @@
 /** A client for the HStreamDB. */
 public interface HStreamClient extends AutoCloseable {
 
-  /** @return a {@link HStreamClientBuilder} */
+  /**
+   * @return a {@link HStreamClientBuilder}
+   */
   static HStreamClientBuilder builder() {
     return new HStreamClientBuilderImpl();
   }
 
-  /** @return a {@link ProducerBuilder} */
+  /**
+   * @return a {@link ProducerBuilder}
+   */
   ProducerBuilder newProducer();
 
   BufferedProducerBuilder newBufferedProducer();
 
-  /** @return a {@link ConsumerBuilder} */
+  /**
+   * @return a {@link ConsumerBuilder}
+   */
   ConsumerBuilder newConsumer();
 
   @Deprecated
-  /** @return a {@link QueryerBuilder} */
+  /**
+   * @return a {@link QueryerBuilder}
+   */
   QueryerBuilder newQueryer();
 
   @Deprecated
-  /** @return a {@link ReaderBuilder} */
+  /**
+   * @return a {@link ReaderBuilder}
+   */
   ReaderBuilder newReader();
 
   StreamShardReaderBuilder newStreamShardReader();

client/src/main/java/io/hstream/StreamKeyReader.java

@@ -1,9 +1,8 @@
 package io.hstream;
 
-
 public interface StreamKeyReader extends AutoCloseable {
 
-    boolean hasNext();
-    ReceivedRecord next();
+  boolean hasNext();
 
+  ReceivedRecord next();
 }

client/src/main/java/io/hstream/StreamKeyReaderBuilder.java

@@ -9,6 +9,7 @@ public interface StreamKeyReaderBuilder {
   StreamKeyReaderBuilder from(StreamShardOffset from);
 
   StreamKeyReaderBuilder until(StreamShardOffset until);
+
   StreamKeyReaderBuilder bufferSize(int bufferSize);
 
   StreamKeyReader build();

client/src/main/java/io/hstream/StreamShardReaderBuilder.java

@@ -7,10 +7,13 @@ public interface StreamShardReaderBuilder {
   StreamShardReaderBuilder shardId(long shardId);
 
   StreamShardReaderBuilder from(StreamShardOffset shardOffset);
+
   StreamShardReaderBuilder maxReadBatches(long maxReadBatches);
+
   StreamShardReaderBuilder until(StreamShardOffset until);
 
   StreamShardReaderBuilder receiver(StreamShardReaderReceiver streamShardReaderReceiver);
+
   StreamShardReaderBuilder batchReceiver(StreamShardReaderBatchReceiver streamShardReaderReceiver);
 
   StreamShardReader build();

client/src/main/java/io/hstream/Subscription.java

@@ -41,7 +41,9 @@ private Subscription(
     this.createdTime = createdTime;
   }
 
-  /** @return {@link Subscription.Builder} */
+  /**
+   * @return {@link Subscription.Builder}
+   */
   public static Builder newBuilder() {
     return new Builder();
   }

client/src/main/java/io/hstream/impl/ConsumerBuilderImpl.java

@@ -2,8 +2,11 @@
 
 import static com.google.common.base.Preconditions.checkArgument;
 
-import io.hstream.*;
-
+import io.hstream.BatchReceiver;
+import io.hstream.Consumer;
+import io.hstream.ConsumerBuilder;
+import io.hstream.HRecordReceiver;
+import io.hstream.RawRecordReceiver;
 import java.util.UUID;
 
 public class ConsumerBuilderImpl implements ConsumerBuilder {
@@ -77,6 +80,13 @@ public Consumer build() {
       ackBufferSize = 1;
     }
     return new ConsumerKtImpl(
-        client, name, subscription, rawRecordReceiver, hRecordReceiver, batchReceiver, ackBufferSize, ackAgeLimit);
+        client,
+        name,
+        subscription,
+        rawRecordReceiver,
+        hRecordReceiver,
+        batchReceiver,
+        ackBufferSize,
+        ackAgeLimit);
   }
 }