Expose Publisher.asAnyWorkflow as public API (#213)

Author: amorde

Samples/WorkflowCombineSampleApp/WorkflowCombineSampleApp/DemoWorker.swift

@@ -17,7 +17,7 @@ extension DemoWorkflow {
 
         // This publisher publishes the current date on a timer that fires every second
         func run() -> AnyPublisher<Output, Never> {
-            Timer.publish(every: 1, on: .main, in: .common)
+            Timer.publish(every: 2, on: .main, in: .common)
                 .autoconnect()
                 .map { Action(publishedDate: $0) }
                 .eraseToAnyPublisher()

Samples/WorkflowCombineSampleApp/WorkflowCombineSampleApp/DemoWorkflow.swift

@@ -46,13 +46,24 @@ extension DemoWorkflow {
 // MARK: Rendering
 
 extension DemoWorkflow {
-    // TODO: Change this to your actual rendering type
     typealias Rendering = DemoScreen
 
     func render(state: DemoWorkflow.State, context: RenderContext<DemoWorkflow>) -> Rendering {
+        // Combine-based worker example
         DemoWorker()
             .rendered(in: context)
 
+        // Directly consume a Publisher
+        Timer.publish(every: 2, on: .main, in: .common)
+            .autoconnect()
+            .delay(for: 1.0, scheduler: DispatchQueue.main)
+            .asAnyWorkflow()
+            .onOutput { state, output in
+                state.date = Date()
+                return nil
+            }
+            .rendered(in: context)
+
         dateFormatter.dateStyle = .long
         dateFormatter.timeStyle = .long
         let formattedDate = dateFormatter.string(from: state.date)

WorkflowCombine/Sources/Publisher+Extensions.swift

@@ -25,7 +25,7 @@ extension Publisher where Failure == Never {
         asAnyWorkflow().mapOutput(transform)
     }
 
-    func asAnyWorkflow() -> AnyWorkflow<Void, Output> {
+    public func asAnyWorkflow() -> AnyWorkflow<Void, Output> {
         PublisherWorkflow(publisher: self).asAnyWorkflow()
     }
 }

WorkflowCombine/Sources/PublisherWorkflow.swift

@@ -21,17 +21,17 @@ import Foundation
 import Workflow
 
 struct PublisherWorkflow<WorkflowPublisher: Publisher>: Workflow where WorkflowPublisher.Failure == Never {
-    public typealias Output = WorkflowPublisher.Output
-    public typealias State = Void
-    public typealias Rendering = Void
+    typealias Output = WorkflowPublisher.Output
+    typealias State = Void
+    typealias Rendering = Void
 
     let publisher: WorkflowPublisher
 
-    public init(publisher: WorkflowPublisher) {
+    init(publisher: WorkflowPublisher) {
         self.publisher = publisher
     }
 
-    public func render(state: State, context: RenderContext<Self>) -> Rendering {
+    func render(state: State, context: RenderContext<Self>) -> Rendering {
         let sink = context.makeSink(of: AnyWorkflowAction.self)
         context.runSideEffect(key: "") { [publisher] lifetime in
             let cancellable = publisher