Implement SingletonInstanceResolver

Author: mythz

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/ServerEventsClient.java

@@ -121,8 +121,9 @@ public IResolver getResolver() {
         return resolver;
     }
 
-    public void setResolver(IResolver resolver) {
+    public ServerEventsClient setResolver(IResolver resolver) {
         this.resolver = resolver;
+        return this;
     }
 
     public ServerEventsClient setOnConnect(ServerEventConnectCallback onConnect) {

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/SingletonInstanceResolver.java

@@ -0,0 +1,30 @@
+package net.servicestack.client.sse;
+
+import net.servicestack.client.IResolver;
+
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+import java.util.function.Function;
+
+/**
+ * Created by mythz on 2/12/2017.
+ */
+
+public class SingletonInstanceResolver implements IResolver {
+
+    ConcurrentMap<Class, Object> cache = new ConcurrentHashMap<>();
+
+    @Override
+    public Object TryResolve(Class cls) {
+        return cache.computeIfAbsent(cls, new Function<Class, Object>() {
+            @Override
+            public Object apply(Class aClass) {
+                try {
+                    return aClass.newInstance();
+                } catch (Exception e) {
+                    throw new RuntimeException(e);
+                }
+            }
+        });
+    }
+}

src/AndroidClient/client/src/test/java/net/servicestack/client/ServerEventClientTests.java

@@ -7,6 +7,7 @@
 import net.servicestack.client.sse.ServerEventLeave;
 import net.servicestack.client.sse.ServerEventMessage;
 import net.servicestack.client.sse.ServerEventsClient;
+import net.servicestack.client.sse.SingletonInstanceResolver;
 import net.servicestack.func.Func;
 
 import java.util.ArrayList;
@@ -556,4 +557,40 @@ public void test_Does_send_raw_string_messages() throws Exception {
             assertEquals("#top", bgImageRequest.getCssSelector());
         }
     }
+
+    public void test_Can_reuse_same_instance() throws Exception {
+        List<ServerEventMessage> msgs1 = new ArrayList<>();
+
+        try(ServerEventsClient client1 = new ServerEventsClient("http://chat.servicestack.net")
+                .registerReceiver(TestJavaScriptReceiver.class)
+                .registerNamedReceiver("css", TestJavaScriptReceiver.class)
+                .setResolver(new SingletonInstanceResolver())
+                .setOnMessage(msgs1::add)
+                .start()
+                .waitTillConnected()) {
+
+            postRaw(client1, "cmd.announce", "This is your captain speaking...");
+
+            while (msgs1.size() < 1) {
+                Thread.sleep(100);
+            }
+
+            TestJavaScriptReceiver instance = (TestJavaScriptReceiver)client1.getResolver().TryResolve(TestJavaScriptReceiver.class);
+            assertEquals("This is your captain speaking...", instance.AnnounceInstance);
+
+            postRaw(client1, "cmd.announce", "2nd Announcement");
+
+            while (msgs1.size() < 2) {
+                Thread.sleep(100);
+            }
+
+            assertEquals("2nd Announcement", instance.AnnounceInstance);
+        }
+    }
+
+    public void test_Can_use_IOC_to_autowire_Receivers(){
+        //No built-in IOC
+    }
+
+    
 }