public class PipeTransport
extends java.lang.Object
implements Transport

Fields
Modifier and Type	Field	Description
`private java.util.concurrent.BlockingQueue<com.google.gson.JsonObject>`	`incoming`
`private boolean`	`isClosed`
`private java.util.concurrent.BlockingQueue<java.lang.String>`	`outgoing`
`private ReaderThread`	`readerThread`
`private WriterThread`	`writerThread`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`com.google.gson.JsonObject`	`poll(java.time.Duration timeout)`
`void`	`send(com.google.gson.JsonObject message)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

private final java.util.concurrent.BlockingQueue<com.google.gson.JsonObject> incoming

private final java.util.concurrent.BlockingQueue<java.lang.String> outgoing

private final ReaderThread readerThread

private final WriterThread writerThread

PipeTransport(java.io.InputStream input,
              java.io.OutputStream output)

public void send(com.google.gson.JsonObject message)

public com.google.gson.JsonObject poll(java.time.Duration timeout)

Class PipeTransport