Add SignalR client results to Java client (#41774)

Author: BrennanConroy

src/SignalR/clients/java/signalr/build.gradle

@@ -5,7 +5,7 @@ buildscript {
     }
   }
   dependencies {
-    classpath "com.diffplug.spotless:spotless-plugin-gradle:3.14.0"
+    classpath "com.diffplug.spotless:spotless-plugin-gradle:6.6.1"
     classpath 'org.junit.platform:junit-platform-gradle-plugin:1.0.0'
   }
 }
@@ -17,7 +17,7 @@ plugins {
 
 allprojects {
     apply plugin: "java-library"
-    apply plugin: "com.diffplug.gradle.spotless"
+    apply plugin: "com.diffplug.spotless"
 
     // If we're run from outside MSBuild, just assign a bogus dev version.
     version project.findProperty('packageVersion') ?: "99.99.99-dev"

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/ActionBase.java

@@ -3,8 +3,10 @@
 
 package com.microsoft.signalr;
 
+import io.reactivex.rxjava3.core.Completable;
+
 interface ActionBase {
     // We can't use the @FunctionalInterface annotation because it's only
     // available on Android API Level 24 and above.
-    void invoke(Object ... params);
+    Completable invoke(Object ... params);
 }

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/CallbackMap.java

@@ -14,14 +14,24 @@ class CallbackMap {
     private final Map<String, List<InvocationHandler>> handlers = new HashMap<>();
     private final ReentrantLock lock = new ReentrantLock();
 
-    public InvocationHandler put(String target, ActionBase action, Type... types) {
+    public InvocationHandler put(String target, Object action, Type... types) {
         try {
             lock.lock();
             InvocationHandler handler = new InvocationHandler(action, types);
             if (!handlers.containsKey(target)) {
                 handlers.put(target, new ArrayList<>());
             }
-            handlers.get(target).add(handler);
+
+            List<InvocationHandler> methodHandlers;
+            methodHandlers = handlers.get(target);
+            if (handler.getHasResult()) {
+                for (InvocationHandler existingHandler : methodHandlers) {
+                    if (existingHandler.getHasResult()) {
+                        throw new RuntimeException(String.format("'%s' already has a value returning handler. Multiple return values are not supported.", target));
+                    }
+                }
+            }
+            methodHandlers.add(handler);
             return handler;
         } finally {
             lock.unlock();

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/Function1Single.java

@@ -0,0 +1,17 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+package com.microsoft.signalr;
+
+import io.reactivex.rxjava3.core.Single;
+
+/**
+ * A callback that takes one parameter.
+ *
+ * @param <T1> The type of the first parameter to the callback.
+ */
+public interface Function1Single<T1, TResult> {
+    // We can't use the @FunctionalInterface annotation because it's only
+    // available on Android API Level 24 and above.
+    Single<TResult> invoke(T1 param1);
+}

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/Function2Single.java

@@ -0,0 +1,18 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+package com.microsoft.signalr;
+
+import io.reactivex.rxjava3.core.Single;
+
+/**
+ * A callback that takes one parameter.
+ *
+ * @param <T1> The type of the first parameter to the callback.
+ * @param <T2> The type of the second parameter to the callback.
+ */
+public interface Function2Single<T1, T2, TResult> {
+    // We can't use the @FunctionalInterface annotation because it's only
+    // available on Android API Level 24 and above.
+    Single<TResult> invoke(T1 param1, T2 param2);
+}

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/Function3Single.java

@@ -0,0 +1,19 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+package com.microsoft.signalr;
+
+import io.reactivex.rxjava3.core.Single;
+
+/**
+ * A callback that takes one parameter.
+ *
+ * @param <T1> The type of the first parameter to the callback.
+ * @param <T2> The type of the second parameter to the callback.
+ * @param <T3> The type of the third parameter to the callback.
+ */
+public interface Function3Single<T1, T2, T3, TResult> {
+    // We can't use the @FunctionalInterface annotation because it's only
+    // available on Android API Level 24 and above.
+    Single<TResult> invoke(T1 param1, T2 param2, T3 param3);
+}

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/Function4Single.java

@@ -0,0 +1,20 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+package com.microsoft.signalr;
+
+import io.reactivex.rxjava3.core.Single;
+
+/**
+ * A callback that takes one parameter.
+ *
+ * @param <T1> The type of the first parameter to the callback.
+ * @param <T2> The type of the second parameter to the callback.
+ * @param <T3> The type of the third parameter to the callback.
+ * @param <T4> The type of the fourth parameter to the callback.
+ */
+public interface Function4Single<T1, T2, T3, T4, TResult> {
+    // We can't use the @FunctionalInterface annotation because it's only
+    // available on Android API Level 24 and above.
+    Single<TResult> invoke(T1 param1, T2 param2, T3 param3, T4 param4);
+}

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/Function5Single.java

@@ -0,0 +1,21 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+package com.microsoft.signalr;
+
+import io.reactivex.rxjava3.core.Single;
+
+/**
+ * A callback that takes one parameter.
+ *
+ * @param <T1> The type of the first parameter to the callback.
+ * @param <T2> The type of the second parameter to the callback.
+ * @param <T3> The type of the third parameter to the callback.
+ * @param <T4> The type of the fourth parameter to the callback.
+ * @param <T5> The type of the fifth parameter to the callback.
+ */
+public interface Function5Single<T1, T2, T3, T4, T5, TResult> {
+    // We can't use the @FunctionalInterface annotation because it's only
+    // available on Android API Level 24 and above.
+    Single<TResult> invoke(T1 param1, T2 param2, T3 param3, T4 param4, T5 param5);
+}

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/Function6Single.java

@@ -0,0 +1,22 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+package com.microsoft.signalr;
+
+import io.reactivex.rxjava3.core.Single;
+
+/**
+ * A callback that takes one parameter.
+ *
+ * @param <T1> The type of the first parameter to the callback.
+ * @param <T2> The type of the second parameter to the callback.
+ * @param <T3> The type of the third parameter to the callback.
+ * @param <T4> The type of the fourth parameter to the callback.
+ * @param <T5> The type of the fifth parameter to the callback.
+ * @param <T6> The type of the sixth parameter to the callback.
+ */
+public interface Function6Single<T1, T2, T3, T4, T5, T6, TResult> {
+    // We can't use the @FunctionalInterface annotation because it's only
+    // available on Android API Level 24 and above.
+    Single<TResult> invoke(T1 param1, T2 param2, T3 param3, T4 param4, T5 param5, T6 param6);
+}

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/Function7Single.java

@@ -0,0 +1,23 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+package com.microsoft.signalr;
+
+import io.reactivex.rxjava3.core.Single;
+
+/**
+ * A callback that takes one parameter.
+ *
+ * @param <T1> The type of the first parameter to the callback.
+ * @param <T2> The type of the second parameter to the callback.
+ * @param <T3> The type of the third parameter to the callback.
+ * @param <T4> The type of the fourth parameter to the callback.
+ * @param <T5> The type of the fifth parameter to the callback.
+ * @param <T6> The type of the sixth parameter to the callback.
+ * @param <T7> The type of the seventh parameter to the callback.
+ */
+public interface Function7Single<T1, T2, T3, T4, T5, T6, T7, TResult> {
+    // We can't use the @FunctionalInterface annotation because it's only
+    // available on Android API Level 24 and above.
+    Single<TResult> invoke(T1 param1, T2 param2, T3 param3, T4 param4, T5 param5, T6 param6, T7 param7);
+}