Apply lint

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

Sources/JetStream/context.swift

@@ -53,11 +53,13 @@ extension JetStreamContext {
         return AckFuture(sub: sub, timeout: self.timeout)
     }
 
-    internal func request<T: Codable>(_ subject: String, message: Data) async throws -> Response<T> {
-        let response = try await self.client.request(message, subject: "\(self.prefix).\(subject)", timeout: self.timeout)
+    internal func request<T: Codable>(_ subject: String, message: Data) async throws -> Response<T>
+    {
+        let response = try await self.client.request(
+            message, subject: "\(self.prefix).\(subject)", timeout: self.timeout)
 
         let decoder = JSONDecoder()
-       // maybe empty is ok if the response type is nil and we can skip this check?
+        // maybe empty is ok if the response type is nil and we can skip this check?
         guard let payload = response.payload else {
             throw JetStreamRequestError("empty response payload")
         }

Sources/JetStream/errors.swift

@@ -534,5 +534,5 @@ public enum Response<T: Codable>: Codable {
 }
 
 func test() {
-//    JetStreamError(code: 400, errorCode: ErrorCode.accountResourcesExceeded, description: nil)
+    //    JetStreamError(code: 400, errorCode: ErrorCode.accountResourcesExceeded, description: nil)
 }

Tests/JetStreamTests/Integration/JetStreamTests.swift

@@ -93,14 +93,14 @@ class JetStreamTests: XCTestCase {
         }
 
         XCTAssertEqual(info.streams, 1)
-        let badInfo: Response<AccountInfo> = try await ctx.request("STREAM.INFO.BAD", message: Data())
+        let badInfo: Response<AccountInfo> = try await ctx.request(
+            "STREAM.INFO.BAD", message: Data())
         guard case .error(let jetStreamAPIResponse) = badInfo else {
             XCTFail("should get error")
             return
         }
 
         XCTAssertEqual(ErrorCode.streamNotFound, jetStreamAPIResponse.error.errorCode)
 
-
     }
 }