94 SocketChannel channel() {
95 return delegate.channel();
96 }
97
98 @Override
99 ConnectionPool.CacheKey cacheKey() {
100 return new ConnectionPool.CacheKey(null, proxyAddr);
101 }
102
103 @Override
104 long write(ByteBuffer[] buffers, int start, int number) throws IOException {
105 return delegate.write(buffers, start, number);
106 }
107
108 @Override
109 long write(ByteBuffer buffer) throws IOException {
110 return delegate.write(buffer);
111 }
112
113 @Override
114 void close() {
115 delegate.close();
116 connected = false;
117 }
118
119 @Override
120 protected ByteBuffer readImpl(int length) throws IOException {
121 return delegate.readImpl(length);
122 }
123
124 @Override
125 CompletableFuture<Void> whenReceivingResponse() {
126 return delegate.whenReceivingResponse();
127 }
128
129 @Override
130 protected int readImpl(ByteBuffer buffer) throws IOException {
131 return delegate.readImpl(buffer);
132 }
133
134 @Override
|
94 SocketChannel channel() {
95 return delegate.channel();
96 }
97
98 @Override
99 ConnectionPool.CacheKey cacheKey() {
100 return new ConnectionPool.CacheKey(null, proxyAddr);
101 }
102
103 @Override
104 long write(ByteBuffer[] buffers, int start, int number) throws IOException {
105 return delegate.write(buffers, start, number);
106 }
107
108 @Override
109 long write(ByteBuffer buffer) throws IOException {
110 return delegate.write(buffer);
111 }
112
113 @Override
114 public void close() {
115 delegate.close();
116 connected = false;
117 }
118
119 @Override
120 protected ByteBuffer readImpl(int length) throws IOException {
121 return delegate.readImpl(length);
122 }
123
124 @Override
125 CompletableFuture<Void> whenReceivingResponse() {
126 return delegate.whenReceivingResponse();
127 }
128
129 @Override
130 protected int readImpl(ByteBuffer buffer) throws IOException {
131 return delegate.readImpl(buffer);
132 }
133
134 @Override
|