Reformat

Author: freya022

ffm-impl/src/main/java/dev/freya02/discord/zstd/ffm/DiscordZstdFFMDecompressor.java

@@ -27,8 +27,7 @@ class DiscordZstdFFMDecompressor extends AbstractZstdDecompressor {
     private boolean invalidated = false;
     private boolean closed = false;
 
-    protected DiscordZstdFFMDecompressor(int bufferSizeHint)
-    {
+    protected DiscordZstdFFMDecompressor(int bufferSizeHint) {
         this.stream = Zstd.ZSTD_createDStream();
 
         int bufferSize = bufferSizeHint == ZSTD_RECOMMENDED_BUFFER_SIZE
@@ -45,8 +44,7 @@ protected DiscordZstdFFMDecompressor(int bufferSizeHint)
     }
 
     @Override
-    public void reset()
-    {
+    public void reset() {
         if (closed)
             throw new IllegalStateException("Decompressor is closed");
 
@@ -55,8 +53,7 @@ public void reset()
     }
 
     @Override
-    public void close()
-    {
+    public void close() {
         if (closed)
             return;
 
@@ -71,8 +68,7 @@ public void close()
      * and always return non-null decompressed data
      */
     @Override
-    public byte[] decompress(byte[] data)
-    {
+    public byte[] decompress(byte[] data) {
         if (closed)
             throw new IllegalStateException("Decompressor is closed");
         if (invalidated)
@@ -83,8 +79,7 @@ public byte[] decompress(byte[] data)
             LOG.trace("Decompressing data {}", Arrays.toString(data));
 
         List<byte[]> chunks = new ArrayList<>();
-        try (Arena arena = Arena.ofConfined())
-        {
+        try (Arena arena = Arena.ofConfined()) {
             // Copy compressed data to native memory
             final MemorySegment inputSegment = MemorySegment.ofArray(data);
             final long inputSize = data.length;

jna-impl/src/main/java/dev/freya02/discord/zstd/jna/ZstdJNADecompressor.java

@@ -23,8 +23,7 @@ public class ZstdJNADecompressor extends AbstractZstdDecompressor {
     private boolean invalidated = false;
     private boolean closed = false;
 
-    protected ZstdJNADecompressor(int bufferSizeHint)
-    {
+    protected ZstdJNADecompressor(int bufferSizeHint) {
         this.stream = ZstdJna.INSTANCE.ZSTD_createDStream();
 
         int bufferSize = bufferSizeHint == ZSTD_RECOMMENDED_BUFFER_SIZE
@@ -37,8 +36,7 @@ protected ZstdJNADecompressor(int bufferSizeHint)
     }
 
     @Override
-    public void reset()
-    {
+    public void reset() {
         if (closed)
             throw new IllegalStateException("Decompressor is closed");
 
@@ -47,8 +45,7 @@ public void reset()
     }
 
     @Override
-    public void close()
-    {
+    public void close() {
         if (closed)
             return;
 
@@ -63,8 +60,7 @@ public void close()
      * and always return non-null decompressed data
      */
     @Override
-    public byte[] decompress(byte[] data)
-    {
+    public byte[] decompress(byte[] data) {
         if (closed)
             throw new IllegalStateException("Decompressor is closed");
         if (invalidated)

jni-impl/src/main/java/dev/freya02/discord/zstd/jni/DiscordZstdJNIDecompressor.java

@@ -20,8 +20,7 @@ class DiscordZstdJNIDecompressor extends AbstractZstdDecompressor {
     private boolean invalidated = false;
     private boolean closed = false;
 
-    protected DiscordZstdJNIDecompressor(int bufferSizeHint)
-    {
+    protected DiscordZstdJNIDecompressor(int bufferSizeHint) {
         this.zds = createDStream();
 
         int bufferSize = bufferSizeHint == ZSTD_RECOMMENDED_BUFFER_SIZE
@@ -34,8 +33,7 @@ protected DiscordZstdJNIDecompressor(int bufferSizeHint)
     }
 
     @Override
-    public void reset()
-    {
+    public void reset() {
         if (closed)
             throw new IllegalStateException("Decompressor is closed");
 
@@ -44,8 +42,7 @@ public void reset()
     }
 
     @Override
-    public void close()
-    {
+    public void close() {
         if (closed)
             return;
 
@@ -54,8 +51,7 @@ public void close()
     }
 
     @Override
-    public byte[] decompress(byte[] data)
-    {
+    public byte[] decompress(byte[] data) {
         if (closed)
             throw new IllegalStateException("Decompressor is closed");
         if (invalidated)
@@ -74,8 +70,12 @@ public byte[] decompress(byte[] data)
     }
 
     private static native long createDStream();
+
     private static native long freeDStream(long zds);
+
     private static native int DStreamOutSize();
+
     private static native long initDStream(long zds);
+
     private static native byte[] decompressMessage(long zds, byte[] buffer, byte[] input);
 }