         return
       }
 
-      guard let method = array[1].stringValue,
-        let params = array[2].arrayValue
-      else {
+      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"

    }
  }

  // MARK: - Private

  private var nextMsgid: UInt32 = 0

  private var socket: Socket?
  private var thread: Thread?
  private let queue = DispatchQueue(
    label: String(reflecting: RxMsgpackRpc.self),
    qos: .userInitiated
  )

  private var stopped = true
  private var singles: [UInt32: SingleResponseObserver] = [:]

    get the response as `Response`.
   */
  public var streamResponses = false

  public let uuid = UUID()

  public init() {
    self.queue = DispatchQueue(
      label: "\(String(reflecting: RxMsgpackRpc.self))-\(self.uuid.uuidString)",
      qos: .userInitiated
    )
  }

  public func run(at path: String) -> Completable {
    Completable.create { completable in
