diff options
author | Andreas Fankhauser hiddenalpha.ch | 2022-11-18 21:47:46 +0100 |
---|---|---|
committer | Andreas Fankhauser hiddenalpha.ch | 2022-11-18 21:47:50 +0100 |
commit | 1f2e9d49616c9abe7f61c820a919bf57fa71b304 (patch) | |
tree | 1475ff37c223b396287531f7a34c5c2503ea91be | |
parent | 213616288ea31ea259368bc83e1f72ba23f0df5d (diff) | |
download | UnspecifiedGarbage-1f2e9d49616c9abe7f61c820a919bf57fa71b304.zip UnspecifiedGarbage-1f2e9d49616c9abe7f61c820a919bf57fa71b304.tar.gz |
Fix some java compile errors
3 files changed, 7 insertions, 7 deletions
diff --git a/src/main/java/ch/hiddenalpha/unspecifiedgarbage/octetstream/ByteChunkOStream.java b/src/main/java/ch/hiddenalpha/unspecifiedgarbage/octetstream/ByteChunkOStream.java index 3d854e6..04688d6 100644 --- a/src/main/java/ch/hiddenalpha/unspecifiedgarbage/octetstream/ByteChunkOStream.java +++ b/src/main/java/ch/hiddenalpha/unspecifiedgarbage/octetstream/ByteChunkOStream.java @@ -1,4 +1,4 @@ -package java.ch.hiddenalpha.unspecifiedgarbage.octetstream; +package ch.hiddenalpha.unspecifiedgarbage.octetstream; import java.io.IOException; import java.io.OutputStream; @@ -13,10 +13,10 @@ public class ByteChunkOStream extends OutputStream { private final int chunkSize; // Hint of how large our produced chunks should be. private byte[] buf; private int bufUsedBytes; // How many bytes actually are in-use. - private final ChunkHandler<byte[]> onChunk; + private final ChunkHandler onChunk; private EndHandler onEnd; - public ByteChunkOStream( int chunkSize, ChunkHandler<byte[]> onChunk, EndHandler onEnd ){ + public ByteChunkOStream( int chunkSize, ChunkHandler onChunk, EndHandler onEnd ){ assert onChunk != null : "ChunkHandler cannot be null"; assert chunkSize >= 1 : "chunk size too small: "+ chunkSize; this.chunkSize = chunkSize; @@ -65,7 +65,7 @@ public class ByteChunkOStream extends OutputStream { public void close() throws IOException { flush(); buf = null; // Think for GC - var tmp = onEnd; + EndHandler tmp = onEnd; onEnd = null; // Reduce probability of calling it multiple times if( tmp != null ){ tmp.run(); diff --git a/src/main/java/ch/hiddenalpha/unspecifiedgarbage/octetstream/CloseNotifyOutputStream.java b/src/main/java/ch/hiddenalpha/unspecifiedgarbage/octetstream/CloseNotifyOutputStream.java index 4bffe61..2e19c52 100644 --- a/src/main/java/ch/hiddenalpha/unspecifiedgarbage/octetstream/CloseNotifyOutputStream.java +++ b/src/main/java/ch/hiddenalpha/unspecifiedgarbage/octetstream/CloseNotifyOutputStream.java @@ -1,4 +1,4 @@ -package java.ch.hiddenalpha.unspecifiedgarbage.octetstream; +package ch.hiddenalpha.unspecifiedgarbage.octetstream; import java.io.FilterOutputStream; import java.io.IOException; @@ -18,8 +18,8 @@ public class CloseNotifyOutputStream extends FilterOutputStream { private final AtomicBoolean isFired = new AtomicBoolean(false); public CloseNotifyOutputStream(OutputStream out, Runnable onClose) { - throw new UnsupportedOperationException("TODO need to delegate close call");/*TODO*/ super(out); + if(true) throw new UnsupportedOperationException("TODO need to delegate close call");/*TODO*/ this.onClose = requireNonNull(onClose); } diff --git a/src/test/java/ch/hiddenalpha/unspecifiedgarbage/format/FormatUtilsTest.java b/src/test/java/ch/hiddenalpha/unspecifiedgarbage/format/FormatUtilsTest.java index f4dcb0d..df7cd48 100644 --- a/src/test/java/ch/hiddenalpha/unspecifiedgarbage/format/FormatUtilsTest.java +++ b/src/test/java/ch/hiddenalpha/unspecifiedgarbage/format/FormatUtilsTest.java @@ -1,4 +1,4 @@ -package ch/hiddenalpha/unspecifiedgarbage/format; +package ch.hiddenalpha.unspecifiedgarbage.format; import org.junit.Assert; import org.junit.Test; |