Skip to content

Commit

Permalink
Make AckFuture immutable
Browse files Browse the repository at this point in the history
Signed-off-by: Tomasz Pietrek <[email protected]>
  • Loading branch information
Jarema committed Apr 26, 2024
1 parent 649c5f2 commit 604f629
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions Sources/JetStream/context.swift
Original file line number Diff line number Diff line change
Expand Up @@ -55,8 +55,8 @@ extension JetStreamContext {
}

struct AckFuture {
var sub: NatsSubscription
var timeout: TimeInterval
let sub: NatsSubscription
let timeout: TimeInterval
func wait() async throws -> Ack {
let response = try await withThrowingTaskGroup(
of: NatsMessage?.self,
Expand Down

0 comments on commit 604f629

Please sign in to comment.