From 5057a20c77ff7b824aea461e955a8d0ffbaacdbc Mon Sep 17 00:00:00 2001 From: Michael Gecht Date: Thu, 14 Nov 2024 19:45:10 +0000 Subject: [PATCH] Run `swift-format` Whoops. --- .../Kafka/Utilities/NaiveQueueExecutor.swift | 29 ++++++++++--------- 1 file changed, 15 insertions(+), 14 deletions(-) diff --git a/Sources/Kafka/Utilities/NaiveQueueExecutor.swift b/Sources/Kafka/Utilities/NaiveQueueExecutor.swift index bff5f0f..d56fd6a 100644 --- a/Sources/Kafka/Utilities/NaiveQueueExecutor.swift +++ b/Sources/Kafka/Utilities/NaiveQueueExecutor.swift @@ -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) + } }