diff options
author | Andreas Fankhauser hiddenalpha.ch | 2023-09-27 23:12:33 +0200 |
---|---|---|
committer | Andreas Fankhauser hiddenalpha.ch | 2023-09-27 23:12:33 +0200 |
commit | b7227a36cc0a825a5003085a1726dcd7407b5743 (patch) | |
tree | 3de8f9fd81f28628f588917cbe58ad2641b15885 /src/main | |
parent | d8ba8f6616d0b9d4581596af3f9a678c38fc1266 (diff) | |
download | UnspecifiedGarbage-b7227a36cc0a825a5003085a1726dcd7407b5743.zip UnspecifiedGarbage-b7227a36cc0a825a5003085a1726dcd7407b5743.tar.gz |
Add notes about gpg. Add another java stream util.
Diffstat (limited to 'src/main')
-rw-r--r-- | src/main/java/ch/hiddenalpha/unspecifiedgarbage/stream/StreamUtils.java | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/src/main/java/ch/hiddenalpha/unspecifiedgarbage/stream/StreamUtils.java b/src/main/java/ch/hiddenalpha/unspecifiedgarbage/stream/StreamUtils.java index 889b3f1..bebe970 100644 --- a/src/main/java/ch/hiddenalpha/unspecifiedgarbage/stream/StreamUtils.java +++ b/src/main/java/ch/hiddenalpha/unspecifiedgarbage/stream/StreamUtils.java @@ -25,6 +25,21 @@ public class StreamUtils { return totalBytes; } + public static Runnable newCopyTask(java.io.InputStream src, java.io.OutputStream dst, boolean doCloseDst){ + return ()->{ + try{ + for( byte[] buf = new byte[8291] ;; ){ + int readLen = src.read(buf, 0, buf.length); + if( readLen == -1 ) break; + dst.write(buf, 0, readLen); + } + if( doCloseDst ) dst.close(); + }catch( java.io.IOException ex ){ + throw new RuntimeException(ex); + } + }; + } + public static <SRC,DST> java.util.Iterator<DST> map( java.util.Iterator<SRC> src , java.util.function.Function<SRC,DST> mapper ) { return new java.util.Iterator<DST>() { @Override public boolean hasNext() { return src.hasNext(); } |