PipeStreams

mill.internal.PipeStreams
class PipeStreams(val bufferSize: Int)

Fork of java.io.Piped{Input,Output}Stream that allows writes to come from separate threads. Really the same logic just with the assertions on thread liveness removed, added some synchronization to ensure atomic writes, and somewhat cleaned up as a single object rather than two loose objects you have to connect together.

Attributes

Source
PipeStreams.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete fields

val bufferSize: Int

Attributes

Source
PipeStreams.scala
val input: InputStream

Attributes

Source
PipeStreams.scala
val output: OutputStream

Attributes

Source
PipeStreams.scala