Ack callback

android/src/main/java/com/gcrabtree/rctsocketio/SocketIoModule.java

@@ -15,12 +15,14 @@
 import com.facebook.react.bridge.ReadableNativeMap;
 import com.facebook.react.bridge.WritableArray;
 import com.facebook.react.bridge.WritableMap;
+import com.facebook.react.bridge.Callback;
 
 import org.json.JSONObject;
 
 import java.net.URISyntaxException;
 import java.util.HashMap;
 
+import io.socket.client.Ack;
 import io.socket.client.IO;
 import io.socket.client.Socket;
 import io.socket.emitter.Emitter;
@@ -63,12 +65,18 @@ public void initialize(String connection, ReadableMap options) {
      * Emit event to server
      * @param event The name of the event.
      * @param items The data to pass through the SocketIo engine to the server endpoint.
+     * @param Ack callback
      */
     @ReactMethod
-    public void emit(String event, ReadableMap items) {
+    public void emit(String event, ReadableMap items, final Callback ack) {
         HashMap<String, Object> map = SocketIoReadableNativeMap.toHashMap((ReadableNativeMap) items);
         if (mSocket != null) {
-            mSocket.emit(event, new JSONObject(map));
+            mSocket.emit(event, new JSONObject(map), new Ack() {
+                @Override
+                public void call(Object... args) {
+                    ack.invoke(SocketIoJSONUtil.objectsFromJSON(args));
+                }
+            });
         }
         else {
             Log.e(TAG, "Cannot execute emit. mSocket is null. Initialize socket first!!!");

android/src/main/java/com/gcrabtree/rctsocketio/SocketIoReadableNativeMap.java

@@ -2,6 +2,7 @@
 
 import android.util.Log;
 
+import com.facebook.jni.HybridData;
 import com.facebook.react.bridge.ReadableMapKeySetIterator;
 import com.facebook.react.bridge.ReadableNativeMap;
 
@@ -15,6 +16,11 @@
 
 public class SocketIoReadableNativeMap extends ReadableNativeMap {
     private static final String TAG = "SIOReadableNativeMap";
+
+    protected SocketIoReadableNativeMap(HybridData hybridData) {
+        super(hybridData);
+    }
+
     /**
      * Note: This will only be necessary until RN version 0.26 goes live
      * It will be deprecated from the project, as this is just included in that version of RN.

gradle/wrapper/gradle-wrapper.properties

@@ -0,0 +1,6 @@
+#Mon Dec 28 10:00:20 PST 2015
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-2.14.1-all.zip

index.js

@@ -16,6 +16,7 @@ class Socket {
     this.handlers = {};
     this.onAnyHandler = null;
 
+    if(Platform.OS === "ios") this.sockets.addListener("socketEvent");
     this.deviceEventSubscription = DeviceEventEmitter.addListener(
       'socketEvent', this._handleEvent.bind(this)
     );
@@ -63,8 +64,8 @@ class Socket {
     this.onAnyHandler = handler;
   }
 
-  emit (event, data) {
-    this.sockets.emit(event, data);
+  emit (event, data, ack = () => console.log(`ACK ${event}`)) {
+    this.sockets.emit(event, data, ack);
   }
 
   joinNamespace (namespace) {