Skip to content

Commit

Permalink
Run swift-format
Browse files Browse the repository at this point in the history
Whoops.
  • Loading branch information
mimischi committed Nov 14, 2024
1 parent 88e24a9 commit 5057a20
Showing 1 changed file with 15 additions and 14 deletions.
29 changes: 15 additions & 14 deletions Sources/Kafka/Utilities/NaiveQueueExecutor.swift
Original file line number Diff line number Diff line change
Expand Up @@ -15,22 +15,23 @@
import Dispatch

final class NaiveQueueExecutor: TaskExecutor {
let queue: DispatchQueue
let queue: DispatchQueue

init(_ queue: DispatchQueue) {
self.queue = queue
}
init(_ queue: DispatchQueue) {
self.queue = queue
}

public func enqueue(_ _job: consuming ExecutorJob) {
let job = UnownedJob(_job)
queue.async {
job.runSynchronously(
on: self.asUnownedTaskExecutor())
public func enqueue(_ _job: consuming ExecutorJob) {
let job = UnownedJob(_job)
queue.async {
job.runSynchronously(
on: self.asUnownedTaskExecutor()
)
}
}
}

@inlinable
public func asUnownedTaskExecutor() -> UnownedTaskExecutor {
UnownedTaskExecutor(ordinary: self)
}
@inlinable
public func asUnownedTaskExecutor() -> UnownedTaskExecutor {
UnownedTaskExecutor(ordinary: self)
}
}

0 comments on commit 5057a20

Please sign in to comment.