File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
sources/net.sf.j2s.ajax/ajaxpipe/net/sf/j2s/ajax Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -178,6 +178,11 @@ public static void switchToContinuumMode() {
178
178
queueNotifying = false ;
179
179
}
180
180
181
+ /**
182
+ * Switch to continuum mode, specifying whether sending notify request back to server in queue or not.
183
+ * @param queue If queue is true, all local pipes' notify requests are sent asynchronously. If queue
184
+ * is false, notify requests are sent one by one in Pipe Live Notifier thread.
185
+ */
181
186
public static void switchToContinuumMode (boolean queue ) {
182
187
pipeMode = MODE_PIPE_CONTINUUM ;
183
188
queueNotifying = queue ;
@@ -333,7 +338,7 @@ public void run() {
333
338
request .registerOnReadyStateChange (new XHRCallbackAdapter () {
334
339
public void onLoaded () {
335
340
String response = request .getResponseText ();
336
- if (response != null && p .notifySequence < sequence ) {
341
+ if (response != null && p .notifySequence < sequence && response . indexOf ( "$p1p3b$" ) != 0 ) {
337
342
p .notifySequence = sequence ;
338
343
}
339
344
if (response != null && response .indexOf ("\" " + PIPE_STATUS_LOST + "\" " ) != -1 ) {
You can’t perform that action at this time.
0 commit comments