lifecycle() {
return lifecyclePublishSubject.toFlowable(BackpressureStrategy.BUFFER);
}
@@ -374,12 +374,17 @@ public class StompClient {
* topic subscription allows for RMQ-style wildcards.
*
*
- * @param pathMatcher Set to {@link SimplePathMatcher} by default
+ * @param matcher Set to {@link SimplePathMatcher} by default
*/
- public void setPathMatcher(PathMatcher pathMatcher) {
- this.pathMatcher = pathMatcher;
+ public void setPathMatcher(PathMatcher matcher) {
+ this.pathMatcher = matcher;
}
+ /**
+ * isConnected
+ *
+ * @return boolean
+ */
public boolean isConnected() {
return getConnectionStream().getValue();
}
@@ -392,11 +397,11 @@ public class StompClient {
*
* Default: Body^@
*
- * @param legacyWhitespace whether to append an extra two newlines
+ * @param ble whether to append an extra two newlines
* @see The STOMP spec
*/
- public void setLegacyWhitespace(boolean legacyWhitespace) {
- this.legacyWhitespace = legacyWhitespace;
+ public void setLegacyWhitespace(boolean ble) {
+ this.legacyWhitespace = ble;
}
/**
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/dto/LifecycleEvent.java b/lib/src/main/java/ua/naiksoftware/stomp/dto/LifecycleEvent.java
index a6096c6..6c88696 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/dto/LifecycleEvent.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/dto/LifecycleEvent.java
@@ -66,22 +66,47 @@ public class LifecycleEvent {
mMessage = message;
}
+ /**
+ * getType
+ *
+ * @return Type
+ */
public Type getType() {
return mType;
}
+ /**
+ * getException
+ *
+ * @return Exception
+ */
public Exception getException() {
return mException;
}
+ /**
+ * getMessage
+ *
+ * @return String
+ */
public String getMessage() {
return mMessage;
}
- public void setHandshakeResponseHeaders(TreeMap handshakeResponseHeaders) {
- this.handshakeResponseHeaders = handshakeResponseHeaders;
+ /**
+ * setHandshakeResponseHeaders
+ *
+ * @param map setHandshakeResponseHeaders
+ */
+ public void setHandshakeResponseHeaders(TreeMap map) {
+ this.handshakeResponseHeaders = map;
}
+ /**
+ * getHandshakeResponseHeaders
+ *
+ * @return TreeMap
+ */
public TreeMap getHandshakeResponseHeaders() {
return handshakeResponseHeaders;
}
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompCommand.java b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompCommand.java
index 69e7812..6836e28 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompCommand.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompCommand.java
@@ -5,7 +5,7 @@ package ua.naiksoftware.stomp.dto;
*
* @since 2021-04-27
*/
-public class StompCommand {
+public final class StompCommand {
/**
* CONNECT
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompHeader.java b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompHeader.java
index 8bfdcd8..d41f5a2 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompHeader.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompHeader.java
@@ -53,14 +53,29 @@ public class StompHeader {
mValue = value;
}
+ /**
+ * getKey
+ *
+ * @return String
+ */
public String getKey() {
return mKey;
}
+ /**
+ * getValue
+ *
+ * @return String
+ */
public String getValue() {
return mValue;
}
+ /**
+ * toString
+ *
+ * @return toString
+ */
@Override
public String toString() {
return "StompHeader{" + mKey + '=' + mValue + '}';
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompMessage.java b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompMessage.java
index 8a31224..2981745 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompMessage.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompMessage.java
@@ -42,14 +42,29 @@ public class StompMessage {
mPayload = payload;
}
+ /**
+ * getStompHeaders
+ *
+ * @return List
+ */
public List getStompHeaders() {
return mStompHeaders;
}
+ /**
+ * getPayload
+ *
+ * @return String
+ */
public String getPayload() {
return mPayload;
}
+ /**
+ * getStompCommand
+ *
+ * @return String
+ */
public String getStompCommand() {
return mStompCommand;
}
@@ -134,6 +149,11 @@ public class StompMessage {
return new StompMessage(command, headers, payload);
}
+ /**
+ * toString
+ *
+ * @return toString
+ */
@Override
public String toString() {
return "StompMessage{" + "command='" + mStompCommand + '\'' + ", headers="
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/SimplePathMatcher.java b/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/SimplePathMatcher.java
index 2c41911..b0e557f 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/SimplePathMatcher.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/SimplePathMatcher.java
@@ -9,7 +9,12 @@ import ua.naiksoftware.stomp.dto.StompMessage;
* @since 2021-04-27
*/
public class SimplePathMatcher implements PathMatcher {
-
+ /**
+ * matches
+ * @param path path
+ * @param msg msg
+ * @return boolean
+ */
@Override
public boolean matches(String path, StompMessage msg) {
String dest = msg.findHeader(StompHeader.DESTINATION);
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/SubscriptionPathMatcher.java b/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/SubscriptionPathMatcher.java
index 648b8fc..26e101b 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/SubscriptionPathMatcher.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/SubscriptionPathMatcher.java
@@ -15,12 +15,19 @@ public class SubscriptionPathMatcher implements PathMatcher {
/**
* SubscriptionPathMatcher
*
- * @param stompClient
+ * @param client
*/
- public SubscriptionPathMatcher(StompClient stompClient) {
- this.stompClient = stompClient;
+ public SubscriptionPathMatcher(StompClient client) {
+ this.stompClient = client;
}
+ /**
+ * matches
+ *
+ * @param path path
+ * @param msg msg
+ * @return boolean
+ */
@Override
public boolean matches(String path, StompMessage msg) {
/**
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/provider/AbstractConnectionProvider.java b/lib/src/main/java/ua/naiksoftware/stomp/provider/AbstractConnectionProvider.java
index 03e850c..44f59f2 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/provider/AbstractConnectionProvider.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/provider/AbstractConnectionProvider.java
@@ -36,6 +36,11 @@ public abstract class AbstractConnectionProvider implements ConnectionProvider {
messagesStream = PublishSubject.create();
}
+ /**
+ * messages
+ *
+ * @return Observable
+ */
@NonNull
@Override
public Observable messages() {
@@ -52,6 +57,11 @@ public abstract class AbstractConnectionProvider implements ConnectionProvider {
*/
protected abstract void rawDisconnect();
+ /**
+ * disconnect
+ *
+ * @return Completable
+ */
@Override
public Completable disconnect() {
return Completable
@@ -70,6 +80,12 @@ public abstract class AbstractConnectionProvider implements ConnectionProvider {
*/
protected abstract void createWebSocketConnection();
+ /**
+ * send
+ *
+ * @param stompMessage stompMessage stompMessage
+ * @return Completable
+ */
@NonNull
@Override
public Completable send(String stompMessage) {
@@ -124,6 +140,11 @@ public abstract class AbstractConnectionProvider implements ConnectionProvider {
messagesStream.onNext(stompMessage);
}
+ /**
+ * lifecycle
+ *
+ * @return Observable
+ */
@NonNull
@Override
public Observable lifecycle() {
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/provider/OkHttpConnectionProvider.java b/lib/src/main/java/ua/naiksoftware/stomp/provider/OkHttpConnectionProvider.java
index 91d37f6..60a74a1 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/provider/OkHttpConnectionProvider.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/provider/OkHttpConnectionProvider.java
@@ -50,6 +50,9 @@ public class OkHttpConnectionProvider extends AbstractConnectionProvider {
mOkHttpClient = okHttpClient;
}
+ /**
+ * rawDisconnect
+ */
@Override
public void rawDisconnect() {
if (openSocket != null) {
@@ -57,6 +60,9 @@ public class OkHttpConnectionProvider extends AbstractConnectionProvider {
}
}
+ /**
+ * createWebSocketConnection
+ */
@Override
protected void createWebSocketConnection() {
Request.Builder requestBuilder = new Request.Builder()
@@ -68,39 +74,24 @@ public class OkHttpConnectionProvider extends AbstractConnectionProvider {
new WebSocketListener() {
@Override
public void onOpen(WebSocket webSocket, @NonNull Response response) {
- LifecycleEvent openEvent = new LifecycleEvent(LifecycleEvent.Type.OPENED);
-
- TreeMap headersAsMap = headersAsMap(response);
-
- openEvent.setHandshakeResponseHeaders(headersAsMap);
- emitLifecycleEvent(openEvent);
+ open(response);
}
-
@Override
public void onMessage(WebSocket webSocket, String text) {
emitMessage(text);
}
-
@Override
public void onMessage(WebSocket webSocket, @NonNull ByteString bytes) {
emitMessage(bytes.utf8());
}
-
@Override
public void onClosed(WebSocket webSocket, int code, String reason) {
- openSocket = null;
- emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
+ closed();
}
-
@Override
public void onFailure(WebSocket webSocket, Throwable t, Response response) {
- String message = t.getMessage();
- debug(message);
- emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.ERROR, new Exception(t)));
- openSocket = null;
- emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
+ failure(t);
}
-
@Override
public void onClosing(final WebSocket webSocket, final int code, final String reason) {
webSocket.close(code, reason);
@@ -110,6 +101,30 @@ public class OkHttpConnectionProvider extends AbstractConnectionProvider {
);
}
+ private void closed() {
+ openSocket = null;
+ emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
+ }
+
+ private void failure(Throwable t) {
+
+ String message = t.getMessage();
+ debug(message);
+ emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.ERROR, new Exception(t)));
+ openSocket = null;
+ emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
+ }
+
+ private void open(Response response) {
+
+ LifecycleEvent openEvent = new LifecycleEvent(LifecycleEvent.Type.OPENED);
+
+ TreeMap headersAsMap = headersAsMap(response);
+
+ openEvent.setHandshakeResponseHeaders(headersAsMap);
+ emitLifecycleEvent(openEvent);
+ }
+
/**
* rawSend
*
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/provider/WebSocketsConnectionProvider.java b/lib/src/main/java/ua/naiksoftware/stomp/provider/WebSocketsConnectionProvider.java
index c5c5c57..932452b 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/provider/WebSocketsConnectionProvider.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/provider/WebSocketsConnectionProvider.java
@@ -43,13 +43,16 @@ public class WebSocketsConnectionProvider extends AbstractConnectionProvider {
* Support UIR scheme ws://host:port/path
*
* @param connectHttpHeaders may be null
- * @param uri uri
+ * @param uri uri
*/
public WebSocketsConnectionProvider(String uri, @Nullable Map connectHttpHeaders) {
mUri = uri;
mConnectHttpHeaders = connectHttpHeaders != null ? connectHttpHeaders : new HashMap<>();
}
+ /**
+ * rawDisconnect
+ */
@Override
public void rawDisconnect() {
try {
@@ -70,46 +73,26 @@ public class WebSocketsConnectionProvider extends AbstractConnectionProvider {
}
mWebSocketClient = new WebSocketClient(URI.create(mUri), new Draft_6455(), mConnectHttpHeaders, 0) {
@Override
- public void onWebsocketHandshakeReceivedAsClient(WebSocket conn, ClientHandshake request, @NonNull ServerHandshake response) throws InvalidDataException {
- HiLog.error(LABEL, "onWebsocketHandshakeReceivedAsClient with response: " + response.getHttpStatus() + " " + response.getHttpStatusMessage());
- mServerHandshakeHeaders = new TreeMap<>();
- Iterator keys = response.iterateHttpFields();
- while (keys.hasNext()) {
- String key = keys.next();
- mServerHandshakeHeaders.put(key, response.getFieldValue(key));
- }
- }
-
+ public void onWebsocketHandshakeReceivedAsClient(WebSocket conn, ClientHandshake request, @NonNull ServerHandshake response) throws InvalidDataException { webtodo(response); }
@Override
public void onOpen(@NonNull ServerHandshake handshakeData) {
- HiLog.error(LABEL, "onOpen with handshakeData: " + handshakeData.getHttpStatus() + " " + handshakeData.getHttpStatusMessage());
- LifecycleEvent openEvent = new LifecycleEvent(LifecycleEvent.Type.OPENED);
- openEvent.setHandshakeResponseHeaders(mServerHandshakeHeaders);
- emitLifecycleEvent(openEvent);
+ open(handshakeData);
}
-
@Override
public void onMessage(String message) {
- HiLog.error(LABEL, "onMessage: " + message);
emitMessage(message);
}
-
@Override
public void onClose(int code, String reason, boolean remote) {
- HiLog.error(LABEL, "onClose: code=" + code + " reason=" + reason + " remote=" + remote);
- isisHaveConnection = false;
- emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
-
- HiLog.error(LABEL, "Disconnect after close.");
- disconnect();
+ closeAny(code, reason, remote);
}
-
@Override
public void onError(Exception ex) {
- HiLog.error(LABEL, ex.toString());
emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.ERROR, ex));
}
};
+
+
if (mUri.startsWith("wss")) {
try {
SSLContext sc = SSLContext.getInstance("TLS");
@@ -118,18 +101,52 @@ public class WebSocketsConnectionProvider extends AbstractConnectionProvider {
mWebSocketClient.setSocket(factory.createSocket());
} catch (Exception e) {
String message = e.getMessage();
- HiLog.error(LABEL,message);
+ HiLog.error(LABEL, message);
}
}
mWebSocketClient.connect();
isisHaveConnection = true;
}
+ private void closeAny(int code, String reason, boolean remote) {
+ HiLog.error(LABEL, "onClose: code=" + code + " reason=" + reason + " remote=" + remote);
+ isisHaveConnection = false;
+ emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
+
+ HiLog.error(LABEL, "Disconnect after close.");
+ disconnect();
+ }
+
+ private void open(ServerHandshake handshakeData) {
+ LifecycleEvent openEvent = new LifecycleEvent(LifecycleEvent.Type.OPENED);
+ openEvent.setHandshakeResponseHeaders(mServerHandshakeHeaders);
+ emitLifecycleEvent(openEvent);
+ }
+
+ private void webtodo(ServerHandshake response) {
+ mServerHandshakeHeaders = new TreeMap<>();
+ Iterator keys = response.iterateHttpFields();
+ while (keys.hasNext()) {
+ String key = keys.next();
+ mServerHandshakeHeaders.put(key, response.getFieldValue(key));
+ }
+ }
+
+ /**
+ * rawSend
+ *
+ * @param stompMessage message to send
+ */
@Override
protected void rawSend(String stompMessage) {
mWebSocketClient.send(stompMessage);
}
+ /**
+ * getSocket
+ *
+ * @return Object
+ */
@Override
protected Object getSocket() {
return mWebSocketClient;
diff --git a/test_server/src/main/groovy/ua/naiksoftware/test_server/Main.java b/test_server/src/main/groovy/ua/naiksoftware/test_server/Main.java
index e9a284b..b432828 100644
--- a/test_server/src/main/groovy/ua/naiksoftware/test_server/Main.java
+++ b/test_server/src/main/groovy/ua/naiksoftware/test_server/Main.java
@@ -4,7 +4,10 @@ import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
-class Main {
+final class Main {
+ private Main() {
+
+ }
static void main(String[] args) {
SpringApplication.run(Main.class, args);
}
diff --git a/test_server/test_server.iml b/test_server/test_server.iml
new file mode 100644
index 0000000..73c63ac
--- /dev/null
+++ b/test_server/test_server.iml
@@ -0,0 +1,89 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
--
Gitee
From 9becdccd55b3a0a6d3497943cef93c9fd81beb9b Mon Sep 17 00:00:00 2001
From: lele <879860859@qq.com>
Date: Tue, 6 Jul 2021 02:26:32 +0000
Subject: [PATCH 08/12] commit
---
.../main/java/ua/naiksoftware/stomp/dto/StompCommand.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompCommand.java b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompCommand.java
index 6836e28..7333397 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompCommand.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompCommand.java
@@ -11,26 +11,32 @@ public final class StompCommand {
* CONNECT
*/
public static final String CONNECT = "CONNECT";
+
/**
* CONNECTED
*/
public static final String CONNECTED = "CONNECTED";
+
/**
* SEND
*/
public static final String SEND = "SEND";
+
/**
* MESSAGE
*/
public static final String MESSAGE = "MESSAGE";
+
/**
* SUBSCRIBE
*/
public static final String SUBSCRIBE = "SUBSCRIBE";
+
/**
* UNSUBSCRIBE
*/
public static final String UNSUBSCRIBE = "UNSUBSCRIBE";
+
/**
* UNKNOWN
*/
--
Gitee
From 79f1fceb1cd17ea3683efd9d02294b83cd7099cb Mon Sep 17 00:00:00 2001
From: lele <879860859@qq.com>
Date: Tue, 6 Jul 2021 02:32:14 +0000
Subject: [PATCH 09/12] commit
---
.../rxHarmony/RxHmOSPlugins.java | 15 +++++++--------
1 file changed, 7 insertions(+), 8 deletions(-)
diff --git a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/RxHmOSPlugins.java b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/RxHmOSPlugins.java
index 9e67756..0919474 100644
--- a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/RxHmOSPlugins.java
+++ b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/RxHmOSPlugins.java
@@ -30,11 +30,11 @@ public final class RxHmOSPlugins {
if (scheduler == null) {
throw new NullPointerException("scheduler == null");
}
- Function, Scheduler> f = onInitMainThreadHandler;
- if (f == null) {
+ Function, Scheduler> function = onInitMainThreadHandler;
+ if (function == null) {
return callRequireNonNull(scheduler);
}
- return applyRequireNonNull(f, scheduler);
+ return applyRequireNonNull(function, scheduler);
}
public static void setMainThreadSchedulerHandler(Function handler) {
@@ -46,16 +46,17 @@ public final class RxHmOSPlugins {
*
* @param scheduler
* @return Scheduler
+ * @throws NullPointerException scheduler == null
*/
public static Scheduler onMainThreadScheduler(Scheduler scheduler) {
if (scheduler == null) {
throw new NullPointerException("scheduler == null");
}
- Function f = onMainThreadHandler;
- if (f == null) {
+ Function function = onMainThreadHandler;
+ if (function == null) {
return scheduler;
}
- return apply(f, scheduler);
+ return apply(function, scheduler);
}
/**
@@ -111,6 +112,4 @@ public final class RxHmOSPlugins {
throw Exceptions.propagate(ex);
}
}
-
-
}
--
Gitee
From 52fdcba56b8251806d3549e367a7fb61db5a21d8 Mon Sep 17 00:00:00 2001
From: lele <879860859@qq.com>
Date: Tue, 6 Jul 2021 02:40:29 +0000
Subject: [PATCH 10/12] commit
---
.../rxHarmony/OpenHarmonySchedulers.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHarmonySchedulers.java b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHarmonySchedulers.java
index 3d6c0cd..134c39b 100644
--- a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHarmonySchedulers.java
+++ b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHarmonySchedulers.java
@@ -18,6 +18,13 @@ public final class OpenHarmonySchedulers {
private static final Scheduler MAIN_THREAD = RxHmOSPlugins.initMainThreadScheduler(
() -> MainHolder.DEFAULT);
+ /**
+ * 构造函数
+ */
+ private OpenHarmonySchedulers() {
+ throw new AssertionError("No instances.");
+ }
+
/**
* 主线程
* *
@@ -28,13 +35,6 @@ public final class OpenHarmonySchedulers {
return RxHmOSPlugins.onMainThreadScheduler(MAIN_THREAD);
}
- /**
- * 构造函数
- */
- private OpenHarmonySchedulers() {
- throw new AssertionError("No instances.");
- }
-
/**
* from 根据 eventRunner 返回 Scheduler
--
Gitee
From 25e230fbce19e0099a2968cde8d507b91e4d4b60 Mon Sep 17 00:00:00 2001
From: lele <879860859@qq.com>
Date: Tue, 6 Jul 2021 02:58:22 +0000
Subject: [PATCH 11/12] commit
---
.../rxHarmony/OpenHandlerScheduler.java | 45 +++++++++----------
1 file changed, 22 insertions(+), 23 deletions(-)
diff --git a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHandlerScheduler.java b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHandlerScheduler.java
index d0c4c08..06e5414 100644
--- a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHandlerScheduler.java
+++ b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHandlerScheduler.java
@@ -73,6 +73,24 @@ final class OpenHandlerScheduler extends Scheduler {
}
}
+ @Override
+ public Disposable scheduleDirect(Runnable run, long delay, TimeUnit unit) {
+ if (run == null) {
+ throw new NullPointerException("run == null");
+ }
+ if (unit == null) {
+ throw new NullPointerException("unit == null");
+ }
+ ScheduledRunnable scheduled = new ScheduledRunnable(handler, RxJavaPlugins.onSchedule(run));
+ handler.postTask(scheduled, unit.toMillis(delay));
+ return scheduled;
+ }
+
+ @Override
+ public Worker createWorker() {
+ return new HandlerWorker(handler);
+ }
+
/**
* ScheduledRunnable
*
@@ -84,28 +102,6 @@ final class OpenHandlerScheduler extends Scheduler {
private volatile boolean isDisposed;
- OpenHandlerScheduler(EventHandler eventHandler) {
- this.handler = eventHandler;
- }
-
- @Override
- public Disposable scheduleDirect(Runnable run, long delay, TimeUnit unit) {
- if (run == null) {
- throw new NullPointerException("run == null");
- }
- if (unit == null) {
- throw new NullPointerException("unit == null");
- }
- ScheduledRunnable scheduled = new ScheduledRunnable(handler, RxJavaPlugins.onSchedule(run));
- handler.postTask(scheduled, unit.toMillis(delay));
- return scheduled;
- }
-
- @Override
- public Worker createWorker() {
- return new HandlerWorker(handler);
- }
-
ScheduledRunnable(EventHandler eventHandler, Runnable runnable) {
this.handler = eventHandler;
this.delegate = runnable;
@@ -128,5 +124,8 @@ final class OpenHandlerScheduler extends Scheduler {
}
}
+ OpenHandlerScheduler(EventHandler eventHandler) {
+ this.handler = eventHandler;
+ }
-}
+}
\ No newline at end of file
--
Gitee
From eae3ee2378aba11fbe95ffce62eda95b54eb8b3c Mon Sep 17 00:00:00 2001
From: lele <879860859@qq.com>
Date: Tue, 6 Jul 2021 03:04:15 +0000
Subject: [PATCH 12/12] commit
---
README.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/README.md b/README.md
index 06e0d5f..2ceef49 100644
--- a/README.md
+++ b/README.md
@@ -155,7 +155,7 @@ CodeCheck代码测试无异常
CloudTest代码测试无异常
-火绒安全病毒安全检测通过
+病毒安全检测通过
当前版本demo功能与原组件基本无差异
--
Gitee