ViaBlockingQueues
mill.rpc.MillRpcWireTransport.ViaBlockingQueues
class ViaBlockingQueues(inQueue: BlockingQueue[String], outQueue: BlockingQueue[String]) extends MillRpcWireTransport
Attributes
- Source
- MillRpcWireTransport.scala
- Graph
-
- Supertypes
Members list
Value members
Concrete methods
Attributes
- Definition Classes
-
AutoCloseable
- Source
- MillRpcWireTransport.scala
Human-readable name of the wire.
Reads one raw message from the wire.
Reads one raw message from the wire.
Attributes
- Definition Classes
- Source
- MillRpcWireTransport.scala
Writes one raw message to the wire.
Inherited methods
final def readAndTryToParse[A : Reader](typeName: String, log: String => Unit, firstInvocation: Boolean): Option[A]
Helper that reads a message from the wire and tries to parse it, logging along the way.
Helper that reads a message from the wire and tries to parse it, logging along the way.
Attributes
- Inherited from:
- MillRpcWireTransport
- Source
- MillRpcWireTransport.scala
def readAndTryToParse[A : Reader](log: String => Unit)(using evidence$1: Reader[A], typeName: TPrint[A]): Option[A]
Helper that reads a message from the wire and tries to parse it, logging along the way.
Helper that reads a message from the wire and tries to parse it, logging along the way.
Attributes
- Inherited from:
- MillRpcWireTransport
- Source
- MillRpcWireTransport.scala
Helper that writes a message to the wire, logging along the way.
Helper that writes a message to the wire, logging along the way.
Attributes
- Inherited from:
- MillRpcWireTransport
- Source
- MillRpcWireTransport.scala
In this article