| /external/webrtc/webrtc/examples/objc/AppRTCDemo/third_party/SocketRocket/ |
| D | SRWebSocket.h | 99 - (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message;
103 - (void)webSocketDidOpen:(SRWebSocket *)webSocket;
104 - (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error;
105 - (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reas…
106 - (void)webSocket:(SRWebSocket *)webSocket didReceivePong:(NSData *)pongPayload;
|
| D | SRWebSocket.m | 149 typedef void (^data_callback)(SRWebSocket *webSocket, NSData *data);
679 if ([self.delegate respondsToSelector:@selector(webSocket:didFailWithError:)]) {
680 [self.delegate webSocket:self didFailWithError:error];
747 if ([self.delegate respondsToSelector:@selector(webSocket:didReceivePong:)]) {
748 [self.delegate webSocket:self didReceivePong:pongData];
757 [self.delegate webSocket:self didReceiveMessage:message];
1108 … if ([self.delegate respondsToSelector:@selector(webSocket:didCloseWithCode:reason:wasClean:)]) {
1109 … [self.delegate webSocket:self didCloseWithCode:_closeCode reason:_closeReason wasClean:YES];
1456 … if ([self.delegate respondsToSelector:@selector(webSocket:didCloseWithCode:reason:wasClean:)]) {
1457 …[self.delegate webSocket:self didCloseWithCode:SRStatusCodeGoingAway reason:@"Stream end encounter…
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
| D | WebSocketCallTest.java | 57 WebSocket webSocket = awaitWebSocket(); in clientPingPong() local
58 webSocket.sendPing(new Buffer().writeUtf8("Hello, WebSockets!")); in clientPingPong()
66 WebSocket webSocket = awaitWebSocket(); in clientMessage() local
67 webSocket.sendMessage(TEXT, new Buffer().writeUtf8("Hello, WebSockets!")); in clientMessage()
73 @Override public void onOpen(final WebSocket webSocket, Response response) { in serverMessage()
77 webSocket.sendMessage(TEXT, new Buffer().writeUtf8("Hello, WebSockets!")); in serverMessage()
95 WebSocket webSocket = awaitWebSocket(); in clientStreamingMessage() local
96 BufferedSink sink = webSocket.newMessageSink(TEXT); in clientStreamingMessage()
106 @Override public void onOpen(final WebSocket webSocket, Response response) { in serverStreamingMessage()
110 BufferedSink sink = webSocket.newMessageSink(TEXT); in serverStreamingMessage()
[all …]
|
| D | AutobahnTester.java | 70 private WebSocket webSocket; in runTest()
72 @Override public void onOpen(WebSocket webSocket, Response response) { in runTest()
74 this.webSocket = webSocket; in runTest()
86 webSocket.sendMessage(type, buffer); in runTest()
120 @Override public void onOpen(WebSocket webSocket, Response response) { in getTestCount()
158 @Override public void onOpen(WebSocket webSocket, Response response) { in updateReports()
|
| D | WebSocketRecorder.java | 46 @Override public void onOpen(WebSocket webSocket, Response response) { in onOpen() argument
|
| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| D | WebSocketEcho.java | 34 @Override public void onOpen(final WebSocket webSocket, Response response) { in onOpen() argument
38 webSocket.sendMessage(TEXT, new Buffer().writeUtf8("Hello...")); in onOpen()
39 webSocket.sendMessage(TEXT, new Buffer().writeUtf8("...World!")); in onOpen()
40 webSocket.sendMessage(BINARY, new Buffer().writeInt(0xdeadbeef)); in onOpen()
41 webSocket.close(1000, "Goodbye, World!"); in onOpen()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | RecordedResponse.java | 35 public final WebSocket webSocket; field in RecordedResponse
39 public RecordedResponse(Request request, Response response, WebSocket webSocket, String body, in RecordedResponse() argument
43 this.webSocket = webSocket; in RecordedResponse()
|
| /external/webrtc/webrtc/examples/objc/AppRTCDemo/ |
| D | ARDWebSocketChannel.m | 128 - (void)webSocketDidOpen:(SRWebSocket *)webSocket {
136 - (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message {
159 - (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error {
164 - (void)webSocket:(SRWebSocket *)webSocket
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| D | WebSocketCall.java | 163 final RealWebSocket webSocket = in createWebSocket() local
167 Internal.instance.connectionSetOwner(connection, webSocket); in createWebSocket()
169 listener.onOpen(webSocket, response); in createWebSocket()
171 while (webSocket.readMessage()) { in createWebSocket()
|
| D | WebSocketListener.java | 36 void onOpen(WebSocket webSocket, Response response); in onOpen() argument
|
| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| D | WebSocketClientFactory.java | 561 …public WebSocketClientConnection(WebSocketClientFactory factory, WebSocket webSocket, EndPoint end… in WebSocketClientConnection() argument
563 …super(webSocket, endPoint, buffers, timeStamp, maxIdleTime, protocol, extensions, draftVersion, ma… in WebSocketClientConnection()
|
| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
| D | MockWebServer.java | 672 final RealWebSocket webSocket =
695 listener.onOpen(webSocket, fancyResponse);
697 while (webSocket.readMessage()) {
|
| /external/nanohttpd/websocket/src/main/java/fi/iki/elonen/ |
| D | NanoWSD.java | 846 WebSocket webSocket = openWebSocket(session); in serve() local
847 Response handshakeResponse = webSocket.getHandshakeResponse(); in serve()
|