From 8f14a9eda15fef9f7153211f98cf446e18859713 Mon Sep 17 00:00:00 2001 From: Shane Friedman Date: Sun, 16 Nov 2025 18:56:52 -0500 Subject: [PATCH] Allow async onCreatePublication callbacks --- Sources/Shared/Publication/Publication.swift | 6 +++--- Sources/Streamer/PublicationOpener.swift | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/Sources/Shared/Publication/Publication.swift b/Sources/Shared/Publication/Publication.swift index daf5c44e9..6045c8123 100644 --- a/Sources/Shared/Publication/Publication.swift +++ b/Sources/Shared/Publication/Publication.swift @@ -169,7 +169,7 @@ public class Publication: Closeable, Loggable { _ manifest: inout Manifest, _ container: inout Container, _ services: inout PublicationServicesBuilder - ) -> Void + ) async -> Void private var manifest: Manifest private var container: Container @@ -185,12 +185,12 @@ public class Publication: Closeable, Loggable { self.servicesBuilder = servicesBuilder } - public mutating func apply(_ transform: Transform?) { + public mutating func apply(_ transform: Transform?) async { guard let transform = transform else { return } - transform(&manifest, &container, &servicesBuilder) + await transform(&manifest, &container, &servicesBuilder) } /// Builds the `Publication` from its parts. diff --git a/Sources/Streamer/PublicationOpener.swift b/Sources/Streamer/PublicationOpener.swift index 2af9d5670..f9db6c90e 100644 --- a/Sources/Streamer/PublicationOpener.swift +++ b/Sources/Streamer/PublicationOpener.swift @@ -93,7 +93,7 @@ public class PublicationOpener { switch await parser.parse(asset: asset, warnings: warnings) { case var .success(builder): for transform in builderTransforms { - builder.apply(transform) + await builder.apply(transform) } return .success(builder.build())