@Test public void testOugtoingStream() { assertEquals(outputStream, tcpSocketRpcConnection.getOutgoingStream()); }
@Override public OutputStream getOutgoingStream() { try { return socket.getOutputStream(); } catch (IOException e) { log.error("Failed to get outgoing stream", e); throw new RuntimeException(e); } }
TcpSocketRpcConnection implements RpcConnection { @Override public OutputStream getOutgoingStream() { try { return socket.getOutputStream(); } catch (IOException e) { log.error("Failed to get outgoing stream", e); throw new RuntimeException(e); } } }
TcpSocketRpcConnection implements RpcConnection { @Override public OutputStream getOutgoingStream() { try { return socket.getOutputStream(); } catch (IOException e) { log.error("Failed to get outgoing stream", e); throw new RuntimeException(e); } } TcpSocketRpcConnection(Socket socket); }
TcpSocketRpcConnection implements RpcConnection { @Override public OutputStream getOutgoingStream() { try { return socket.getOutputStream(); } catch (IOException e) { log.error("Failed to get outgoing stream", e); throw new RuntimeException(e); } } TcpSocketRpcConnection(Socket socket); @Override InputStream getIncomingStream(); @Override OutputStream getOutgoingStream(); @Override void close(); @Override String toString(); }
TcpSocketRpcConnection implements RpcConnection { @Override public OutputStream getOutgoingStream() { try { return socket.getOutputStream(); } catch (IOException e) { log.error("Failed to get outgoing stream", e); throw new RuntimeException(e); } } TcpSocketRpcConnection(Socket socket); @Override InputStream getIncomingStream(); @Override OutputStream getOutgoingStream(); @Override void close(); @Override String toString(); static final Logger log; }