(Endpoint client_endpoint, Endpoint server_endpoint)
| 42 | private PipedOutputStream flow_controlled_server_output; |
| 43 | |
| 44 | public DuplexAsync(Endpoint client_endpoint, Endpoint server_endpoint) throws Exception { |
| 45 | this.client = client_endpoint; |
| 46 | this.server = server_endpoint; |
| 47 | client_input = (client_endpoint != null) ? client_endpoint.getInputStream() : null; |
| 48 | client_output = (client_endpoint != null) ? client_endpoint.getOutputStream() : null; |
| 49 | server_input = (server_endpoint != null) ? server_endpoint.getInputStream() : null; |
| 50 | server_output = (server_endpoint != null) ? server_endpoint.getOutputStream() : null; |
| 51 | |
| 52 | flow_controlled_client_output = new PipedOutputStream(); |
| 53 | flow_controlled_client_input = new PipedInputStream(flow_controlled_client_output, 65536); |
| 54 | |
| 55 | flow_controlled_server_output = new PipedOutputStream(); |
| 56 | flow_controlled_server_input = new PipedInputStream(flow_controlled_server_output, 65536); |
| 57 | |
| 58 | client_to_server = createClientToServerSimplex(client_input, flow_controlled_server_output); |
| 59 | server_to_client = createServerToClientSimplex(server_input, flow_controlled_client_output); |
| 60 | |
| 61 | disableDuplexEventListener(); |
| 62 | } |
| 63 | |
| 64 | @Override |
| 65 | public boolean isListenPort(int listenPort) { |
nothing calls this directly
no test coverage detected