diff options
author | Li Haoyi <haoyi.sg@gmail.com> | 2018-05-22 21:46:45 -0700 |
---|---|---|
committer | Li Haoyi <haoyi.sg@gmail.com> | 2018-05-22 21:46:45 -0700 |
commit | c04bfa1c0ee5a51ef5f63ade8e63d1f55f53fa3e (patch) | |
tree | ef3a2b179864b91fab91b45f59b787dd1dacfc88 /main/src | |
parent | 6e60ce3d921a9b5e4ced628e2014b707ce2bbbee (diff) | |
download | mill-c04bfa1c0ee5a51ef5f63ade8e63d1f55f53fa3e.tar.gz mill-c04bfa1c0ee5a51ef5f63ade8e63d1f55f53fa3e.tar.bz2 mill-c04bfa1c0ee5a51ef5f63ade8e63d1f55f53fa3e.zip |
Migrate `ProxyOutputStream` to the `main.client` module, add unit/fuzz tests to make sure it works
Diffstat (limited to 'main/src')
-rw-r--r-- | main/src/mill/main/MillServerMain.scala | 23 |
1 files changed, 0 insertions, 23 deletions
diff --git a/main/src/mill/main/MillServerMain.scala b/main/src/mill/main/MillServerMain.scala index 24e49fbe..2fea4bd8 100644 --- a/main/src/mill/main/MillServerMain.scala +++ b/main/src/mill/main/MillServerMain.scala @@ -224,27 +224,4 @@ object Server{ } } -class ProxyOutputStream(out: java.io.OutputStream, - key: Int) extends java.io.OutputStream { - override def write(b: Int) = out.synchronized{ - out.write(key) - out.write(b) - } - - override def write(b: Array[Byte]): Unit = out.synchronized{ - write(b, 0, b.length) - } - - override def write(b: Array[Byte], off: Int, len: Int): Unit = out.synchronized{ - var i = off - while(i < len){ - val chunkLength = math.min(len - i, 127) - out.write(chunkLength * key) - out.write(b, i, chunkLength) - i += chunkLength - } - } - override def flush() = out.flush() - override def close() = out.close() -} |