           return
         }
 
-        if !expectsReturnValue {
-          single(.success(self.nilResponse(with: msgid)))
-        }
+        if !expectsReturnValue { single(.success(self.nilResponse(with: msgid))) }
       }
 
       return Disposables.create()

  public func run(at path: String) -> Completable {
    Completable.create { completable in
      self.queue.async {
        self.stopped = false

        do {
          try self.socket = Socket.create(
            family: .unix,
            type: .stream,
            proto: .unix
          )
          try self.socket?.connect(to: path)
          self.setUpThreadAndStartReading()
        } catch {
          self.streamSubject.onError(
            Error(msg: "Could not get socket", cause: error)
          )
          completable(.error(
            Error(msg: "Could not get socket at \(path)", cause: error)
          ))
        }

        completable(.completed)

          ]
        )

        if self.socket?.remoteConnectionClosed == true {
          single(.error(Error(
            msg: "Connection stopped, but trying to send a request with msg id \(msgid)"
          )))
          return
        }

        guard let socket = self.socket else {
          single(.error(Error(
            msg: "Socket is invalid, but trying to send a request with msg id \(msgid)"
          )))
          return
        }
