clientthread: implement executor and make Schedulers.single() use it

runelite-client/src/main/java/net/runelite/client/callback/ClientThread.java

@@ -25,21 +25,38 @@
 package net.runelite.client.callback;
 
 import com.google.inject.Inject;
+import io.reactivex.rxjava3.plugins.RxJavaPlugins;
+import io.reactivex.rxjava3.schedulers.Schedulers;
 import java.util.Iterator;
 import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.concurrent.Executor;
 import java.util.function.BooleanSupplier;
 import javax.inject.Singleton;
 import lombok.extern.slf4j.Slf4j;
 import net.runelite.api.Client;
+import org.jetbrains.annotations.NotNull;
 
 @Singleton
 @Slf4j
-public class ClientThread
+public class ClientThread implements Executor
 {
 	private final ConcurrentLinkedQueue<BooleanSupplier> invokes = new ConcurrentLinkedQueue<>();
 
+	private final Client client;
+
 	@Inject
-	private Client client;
+	private ClientThread(Client client)
+	{
+		this.client = client;
+		
+		RxJavaPlugins.setSingleSchedulerHandler(old -> Schedulers.from(this));
+	}
+
+	@Override
+	public void execute(@NotNull Runnable r)
+	{
+		invoke(r);
+	}
 
 	public void invoke(Runnable r)
 	{