     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

        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"

      return
    }

    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"
      ))
