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

          self.queue.async { self.cleanUpAndCloseSocket() }
          return
        }
      } while !self.queue.sync { self.stopped }
    }

    self.thread?.start()

          ]
        )

        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
        }
