Skip to content

Commit

Permalink
Spelling fix: s/cancellAll/cancelAll/
Browse files Browse the repository at this point in the history
  • Loading branch information
lhoward committed Nov 11, 2024
1 parent 3de9f8a commit af1345a
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions FlyingSocks/Sources/SocketPool.swift
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ public final actor SocketPool<Queue: EventQueue>: AsyncSocketPool {
public func run() async throws {
guard state == .ready else { throw Error("Not Ready") }
state = .running
defer { cancellAll() }
defer { cancelAll() }

repeat {
if waiting.isEmpty {
Expand Down Expand Up @@ -151,11 +151,11 @@ public final actor SocketPool<Queue: EventQueue>: AsyncSocketPool {
case complete
}

private func cancellAll() {
logger.logInfo("SocketPoll cancellAll")
private func cancelAll() {
logger.logInfo("SocketPoll cancelAll")
try? queue.stop()
state = .complete
waiting.cancellAll()
waiting.cancelAll()
waiting = Waiting()
if let loop {
self.loop = nil
Expand Down Expand Up @@ -270,7 +270,7 @@ public final actor SocketPool<Queue: EventQueue>: AsyncSocketPool {
}
}

mutating func cancellAll() {
mutating func cancelAll() {
let continuations = storage.values.flatMap(\.values).map(\.continuation)
storage = [:]
for continuation in continuations {
Expand Down

0 comments on commit af1345a

Please sign in to comment.