summaryrefslogtreecommitdiff
path: root/main/src
diff options
context:
space:
mode:
authorLi Haoyi <haoyi.sg@gmail.com>2018-05-22 21:46:45 -0700
committerLi Haoyi <haoyi.sg@gmail.com>2018-05-22 21:46:45 -0700
commitc04bfa1c0ee5a51ef5f63ade8e63d1f55f53fa3e (patch)
treeef3a2b179864b91fab91b45f59b787dd1dacfc88 /main/src
parent6e60ce3d921a9b5e4ced628e2014b707ce2bbbee (diff)
downloadmill-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.scala23
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()
-}