Skip to content

Commit

Permalink
KafkaProducer: rename killPollLoop -> terminatePollLoop
Browse files Browse the repository at this point in the history
  • Loading branch information
felixschlegel committed Jun 29, 2023
1 parent 2769ef7 commit 69ca486
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions Sources/SwiftKafka/KafkaProducer.swift
Original file line number Diff line number Diff line change
Expand Up @@ -258,7 +258,7 @@ public final class KafkaProducer {
case .poll(let client):
client.poll(timeout: 0)
try await Task.sleep(for: self.config.pollInterval)
case .killPollLoop:
case .terminatePollLoop:
return
}
}
Expand Down Expand Up @@ -400,8 +400,8 @@ extension KafkaProducer {
enum PollLoopAction {
/// Poll client for new consumer messages.
case poll(client: KafkaClient)
/// Kill the poll loop.
case killPollLoop
/// Terminate the poll loop.
case terminatePollLoop
}

/// Returns the next action to be taken when wanting to poll.
Expand All @@ -415,7 +415,7 @@ extension KafkaProducer {
case .started(let client, _, _, _):
return .poll(client: client)
case .finished:
return .killPollLoop
return .terminatePollLoop
}
}

Expand Down

0 comments on commit 69ca486

Please sign in to comment.