public TunnelChannel(WritableByteChannel incomingChannel, Closeable closeable) { this.forwarder = new HttpTunnelPayloadForwarder(incomingChannel); this.closeable = closeable; openNewConnection(null); }
public ServerThread(ByteChannel targetServer) { Assert.notNull(targetServer, "TargetServer must not be null"); this.targetServer = targetServer; this.httpConnections = new ArrayDeque<HttpConnection>(2); this.payloadForwarder = new HttpTunnelPayloadForwarder(targetServer); }