                     if let data = text.dataUsingEncoding(NSUTF8StringEncoding) {
                         if let dict = try! NSJSONSerialization.JSONObjectWithData(data, options: NSJSONReadingOptions()) as? NSDictionary {
                             if let obj = super.parseDict(dict) {
-                                completion(obj)
+                                next(obj)
                             }
                         }
                     }

        
        ws.event.close = { code, reason, clean in
            print("WEBSOCKET: CLOSED")
        }
        ws.event.error = { error in
            print("WEBSOCKET ERROR: \(error)")
        }
        ws.event.open = {
            print("WEBSOCKET: OPENED")


public class WSClient : RestClient {
    
    public func watch(next: ((AnyObject) -> Void), completion: () -> Void, failure: (ErrorType) -> Void) -> WebSocket {
        
        
        let request = NSMutableURLRequest(URL: NSURL(string:super.pushUrl!)!)
        if let accessToken : String = super.accessToken() {
