Changeset 108

Timestamp:

08/04/06 04:00:56 (2 years ago)

Author:

robin

Message:

blackmile working with latest streamservice

Files:

• streamservice/trunk/lib/streamservice/Dispatch.js (modified) (7 diffs)

streamservice/trunk/lib/streamservice/Dispatch.js

@@ -349 +349 @@
-streamservice.XMLHttpRequestProtocol.prototype = {
-    response_error : function(err) {
-
+
+
+
-    },
-
@@ -355 +357 @@
-
-        var data = streamservice.join_json(queryitems, replyitems);
+        log("poll:" + MochiKit.Base.repr(data));
-        
-        try{
@@ -380 +383 @@
-            var getresult = function(req){
-                /*return split_json(req.responseText);*/
-
+
+
-            }
-            return MochiKit.Async.sendXMLHttpRequest(this.req).addCallbacks(
@@ -511 +515 @@
-
-    _continue_polling : function (result){
-
+ /*log("continue polling ?");*/
-        if(this.polling_observer != null){
+            /*log("delegate to observer");*/
-            this.polling_observer.handle_queryitems.apply(
-                this.polling_observer, [this, result]);
@@ -596 +601 @@
-
-    handle_query : function(item){
-
+
-        observertag = this.dispatcher.strip_tag(item[0]);
-        observerid = observertag.split(this.TAG_SEPERATOR,1)[0];
@@ -615 +620 @@
-
-    handle_queryitems : function(dispatcher, queryitems){
-
+
+
+
-            this.handle_query));
+            } catch (e) {
+                log(MochiKit.Base.repr(e));
+                }
-    },
-
@@ -645 +655 @@
-    
-    handle_query : function(body, tag, responseback){
+        log("streamservice.Observer.handle_query");
-        if (this.client_dispatcher){
-            this.client_dispatcher(body, tag).addBoth(responseback);