本文整理汇总了Java中com.koushikdutta.async.http.socketio.SocketIOClient类的典型用法代码示例。如果您正苦于以下问题:Java SocketIOClient类的具体用法?Java SocketIOClient怎么用?Java SocketIOClient使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SocketIOClient类属于com.koushikdutta.async.http.socketio包,在下文中一共展示了SocketIOClient类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testSendAcknowledge
import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void testSendAcknowledge() throws Exception {
final TriggerFuture trigger = new TriggerFuture();
SocketIOClient client = SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), "http://koush.clockworkmod.com:8080/", null).get();
client.setStringCallback(new StringCallback() {
boolean isEcho = true;
@Override
public void onString(String string, Acknowledge acknowledge) {
if (!isEcho) {
trigger.trigger("hello".equals(string));
return;
}
assertNotNull(acknowledge);
isEcho = false;
acknowledge.acknowledge(new JSONArray().put(string));
}
});
client.emit("hello");
assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
}
开发者ID:jacklongway,项目名称:LiteSDK,代码行数:23,代码来源:SocketIOTests.java
示例2: testEndpoint
import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void testEndpoint() throws Exception {
final TriggerFuture trigger = new TriggerFuture();
SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), new SocketIORequest("http://koush.clockworkmod.com:8080/", "/chat"), new ConnectCallback() {
@Override
public void onConnectCompleted(Exception ex, SocketIOClient client) {
assertNull(ex);
client.setStringCallback(new StringCallback() {
@Override
public void onString(String string, Acknowledge acknowledge) {
trigger.trigger("hello".equals(string));
}
});
client.emit("hello");
}
});
assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
}
开发者ID:jacklongway,项目名称:LiteSDK,代码行数:18,代码来源:SocketIOTests.java
示例3: onConnectCompleted
import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
/**
* Socket connection callback
*
* @param ex potential exception if error
* @param client socket client
*/
@Override
public void onConnectCompleted(final Exception ex, final SocketIOClient client) {
handler.post(new Runnable() {
@Override
public void run() {
if (ex != null) {
postError();
return;
}
ioState = IOState.CONNECTED;
socketIOClient = client;
socketIOClient.setErrorCallback(ChatService.this);
socketIOClient.setDisconnectCallback(ChatService.this);
socketIOClient.addListener(ChatService.this);
showForeground();
post();
}
});
}
开发者ID:RomainPiel,项目名称:meatspace-android,代码行数:31,代码来源:ChatService.java
示例4: testAcknowledge
import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void testAcknowledge() throws Exception {
final TriggerFuture trigger = new TriggerFuture();
SocketIOClient client = SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), "http://koush.clockworkmod.com:8080/", null).get();
client.emit("hello", new Acknowledge() {
@Override
public void acknowledge(JSONArray arguments) {
trigger.trigger("hello".equals(arguments.optString(0)));
}
});
assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
}
开发者ID:jacklongway,项目名称:LiteSDK,代码行数:14,代码来源:SocketIOTests.java
示例5: WebRTCCliente
import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public WebRTCCliente(RTCListener listener, String host) {
mListener = listener;
factory = new PeerConnectionFactory();
SocketIOClient.connect(host, new ConnectCallback() {
@Override
public void onConnectCompleted(Exception ex, SocketIOClient socket) {
if (ex != null) {
mListener.onStatusChanged("No se puedo conectar al Servidor WebSocket en la direccion: " + ex.getMessage());
//Log.e(TAG,"WebRTCCliente connect failed: "+ex.getMessage());
return;
}
mListener.onStatusChanged("Conectado al Servidor WebSocket.");
// Log.d(TAG, "Conectado al Servidor WebRTC.");
MainActivity.conectado_servidor = true;
client = socket;
// specify which events you are interested in receiving
client.addListener("id", messageHandler);
client.addListener("message", messageHandler);
}
}, new Handler());
iceServers.add(new PeerConnection.IceServer("stun:23.21.150.121"));
iceServers.add(new PeerConnection.IceServer("stun:stun.l.google.com:19302"));
// Habilitar el uso de Datachannels 30.09/2014
// pcConstraints.optional.add(new MediaConstraints.KeyValuePair("RtpDataChannels", "true"));
//
pcConstraints.mandatory.add(new MediaConstraints.KeyValuePair("OfferToReceiveAudio", "false"));
pcConstraints.mandatory.add(new MediaConstraints.KeyValuePair("OfferToReceiveVideo", "true"));
}
开发者ID:KashaMalaga,项目名称:UMA-AndroidWebRTC,代码行数:36,代码来源:WebRTCCliente.java
示例6: connect
import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void connect(Context context, ConnectCallback callback) {
SocketIOClient.connect(
PreferencesHelper.getBaseUrl(context), callback, new Handler());
}
开发者ID:RomainPiel,项目名称:meatspace-android,代码行数:5,代码来源:ApiManager.java
示例7: disconnect
import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void disconnect(SocketIOClient client) {
client.disconnect();
}
开发者ID:RomainPiel,项目名称:meatspace-android,代码行数:4,代码来源:ApiManager.java
注:本文中的com.koushikdutta.async.http.socketio.SocketIOClient类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论