- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for isopen (0.17 sec)
-
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java
private final File path; public UnixDomainSocketFactory(File path) { this.path = path; } @Override public Socket createSocket() throws IOException { UnixSocketChannel channel = UnixSocketChannel.open(); return new TunnelingUnixSocket(path, channel); } @Override public Socket createSocket(String host, int port) throws IOException { Socket result = createSocket(); try {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 03 21:33:52 GMT 2023 - 2.1K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java
this.endpoint = (InetSocketAddress) endpoint; UnixSocketAddress address = new UnixSocketAddress(path); serverSocketChannel = UnixServerSocketChannel.open(); serverSocketChannel.configureBlocking(true); serverSocketChannel.socket().bind(address); } @Override public int getLocalPort() { return 1; // A white lie. There is no local port. }
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Feb 12 16:33:52 GMT 2019 - 3.1K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
client.newWebSocket(request, this); // Trigger shutdown of the dispatcher's executor so this process exits immediately. client.dispatcher().executorService().shutdown(); } @Override public void onOpen(WebSocket webSocket, Response response) { webSocket.send("Hello..."); webSocket.send("...World!"); webSocket.send(ByteString.decodeHex("deadbeef")); webSocket.close(1000, "Goodbye, World!"); }
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 04 11:40:21 GMT 2024 - 1.6K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/RtmSession.java
} // TODO(jwilson): can I read the response body? Do I have to? // the body from slack is a 0-byte-buffer @Override public synchronized void onOpen(WebSocket webSocket, Response response) { System.out.println("onOpen: " + response); } // TOOD(jwilson): decode incoming messages and dispatch them somewhere. @Override public void onMessage(WebSocket webSocket, String text) {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Nov 19 20:16:58 GMT 2016 - 2.4K bytes - Viewed (0)