       return
     }
 
-    guard let rawType = array[0].uint64Value,
-      let type = MessageType(rawValue: rawType)
-    else {
+    guard let rawType = array[0].uint64Value, let type = MessageType(rawValue: rawType) else {
       self.streamSubject.onNext(.error(
         value: unpacked, msg: "Could not get the type of the message"
       ))


        completable(.completed)
      }
      return Disposables.create()
    }
  }

        return
      }

      guard let method = array[1].stringValue, let params = array[2].arrayValue else {
        self.streamSubject.onNext(.error(
          value: unpacked,
          msg: "Could not get the method and params"
