Starting new documentation structure

Documentation/Bibliography.md

@@ -0,0 +1 @@
+

Playgrounds/SwiftCoroutines.playground/Pages/00a-Introduction (Examples).xcplaygroundpage/Contents.swift → Playgrounds/FreeCombine.playground/Pages/00a-Introduction (Examples).xcplaygroundpage/Contents.swift

@@ -82,7 +82,7 @@ Task {
     try await fsubject2.send("hello, combined world!")
     try await fsubject1.finish()
     try await fsubject2.finish()
-    let finalDemand = try await fcancellable.task.value
+    let finalDemand = try await fcancellable.value
     print(finalDemand)
 }
 

Playgrounds/Operators.playground/Contents.swift

@@ -0,0 +1,3 @@
+import UIKit
+
+var greeting = "Hello, playground"

Playgrounds/Operators.playground/Pages/01-Map.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Operators.playground/Pages/02-FlatMap.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Operators.playground/Pages/03-Zip.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Operators.playground/Pages/04-Reduce.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Operators.playground/Pages/05-Filter.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Operators.playground/contents.xcplayground

@@ -0,0 +1,4 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<playground version='5.0' target-platform='ios' buildActiveScheme='true' executeOnSourceChanges='false' importAppTypes='true'>
+    <timeline fileName='timeline.xctimeline'/>
+</playground>

Playgrounds/Operators.playground/timeline.xctimeline

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Timeline
+   version = "3.0">
+   <TimelineItems>
+   </TimelineItems>
+</Timeline>

Playgrounds/Publishers.playground/Contents.swift

@@ -0,0 +1,3 @@
+import UIKit
+
+var greeting = "Hello, playground"

Playgrounds/Publishers.playground/Pages/01-Just.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/02-Empty.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/03-Fail.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/04-Unfolded.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/05-Deferred.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/06-Concat.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/07-Zipped.xcplaygroundpage/Contents.swift

@@ -0,0 +1,30 @@
+//: [Previous](@previous)
+
+import FreeCombine
+import PlaygroundSupport
+PlaygroundPage.current.needsIndefiniteExecution = true
+
+var count = 0
+var publisher1 = (0 ... 100).asyncPublisher
+var publisher2 = "abcdefghijklmnopqrstuvwxyz".asyncPublisher
+
+let cancellable = Zipped(publisher1, publisher2)
+    .map { ($0.0 + 100, $0.1.uppercased()) }
+    .sink(onStartup: .none) { result in
+        switch result {
+            case let .value(value):
+                print(value)
+                count += 1
+            case let .completion(.failure(error)):
+                print("WTF? \(error)")
+            case .completion(.finished):
+                print("Done")
+            case .completion(.cancelled):
+                print("Cancelled")
+        }
+        return .more
+    }
+
+cancellable
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/08-Merged.xcplaygroundpage/Contents.swift

@@ -0,0 +1,33 @@
+//: [Previous](@previous)
+import FreeCombine
+import PlaygroundSupport
+import _Concurrency
+
+PlaygroundPage.current.needsIndefiniteExecution = true
+
+var publisher1 = "01234567890123".asyncPublisher
+var publisher2 = "abcdefghijklmnopqrstuvwxyz".asyncPublisher
+
+Task {
+    let c = await Merged(publisher1, publisher2)
+    .map { $0.uppercased() }
+    .sink({ result in
+        switch result {
+            case let .value(value):
+                print(value)
+                return .more
+            case let .completion(.failure(error)):
+                print("WTF? \(error)")
+                return .done
+            case .completion(.finished):
+                print("Done")
+                return .done
+            case .completion(.cancelled):
+                print("Done")
+                return .done
+        }
+    })
+    _ = try await c.value
+}
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/09-CombineLatest.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/10-Heartbeat.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Publishers.playground/Pages/11-FireAndForget.xcplaygroundpage/Contents.swift

@@ -0,0 +1,7 @@
+//: [Previous](@previous)
+
+import Foundation
+
+var greeting = "Hello, playground"
+
+//: [Next](@next)

Playgrounds/Publishers.playground/contents.xcplayground

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<playground version='6.0' target-platform='ios' buildActiveScheme='true' importAppTypes='true'>
+    <pages>
+        <page name='01-Just'/>
+        <page name='02-Empty'/>
+        <page name='03-Fail'/>
+        <page name='04-Unfolded'/>
+        <page name='05-Deferred'/>
+        <page name='06-Concat'/>
+        <page name='07-Zipped'/>
+        <page name='08-Merged'/>
+        <page name='09-CombineLatest'/>
+        <page name='10-Heartbeat'/>
+        <page name='11-FireAndForget'/>
+    </pages>
+</playground>

Playgrounds/Publishers.playground/timeline.xctimeline

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Timeline
+   version = "3.0">
+   <TimelineItems>
+   </TimelineItems>
+</Timeline>

README.md

@@ -2,6 +2,8 @@
 
 * Protocol-free.
 * Race-free.
+* Yield-free.
+* Sleep-free.
 * Lock-free.
 * Leak-free.
 * Dependency-free.

Sources/FreeCombine/Combinator/ZipState.swift

@@ -11,7 +11,6 @@ struct ZipState<Left: Sendable, Right: Sendable>: CombinatorState {
         case setRight(AsyncStream<Right>.Result, UnsafeContinuation<Demand, Swift.Error>)
     }
 
-    let channel: Channel<ZipState<Left, Right>.Action>
     let downstream: (AsyncStream<(Left, Right)>.Result) async throws -> Demand
     let leftCancellable: Cancellable<Demand>
     let rightCancellable: Cancellable<Demand>
@@ -27,7 +26,6 @@ struct ZipState<Left: Sendable, Right: Sendable>: CombinatorState {
         left: Publisher<Left>,
         right: Publisher<Right>
     ) async {
-        self.channel = channel
         self.downstream = downstream
         self.mostRecentDemand = mostRecentDemand
         self.leftCancellable = await channel.consume(publisher: left, using: ZipState<Left, Right>.Action.setLeft)

Sources/FreeCombine/Filter/Filter.swift

@@ -0,0 +1,22 @@
+//
+//  File.swift
+//  
+//
+//  Created by Van Simmons on 6/4/22.
+//
+public extension Publisher {
+    func filter(
+        _ isIncluded: @escaping (Output) async -> Bool
+    ) -> Self {
+        .init { continuation, downstream in
+            self(onStartup: continuation) { r in
+                switch r {
+                case .value(let a):
+                    guard await isIncluded(a) else { return .more }
+                    return try await downstream(r)
+                case let .completion(value):
+                    return try await downstream(.completion(value))
+            } }
+        }
+    }
+}

Sources/FreeCombine/Publishers/Combinator.swift

@@ -41,7 +41,6 @@ public extension Publisher {
                     stateTask.cancel()
                     onCancel()
                 }) {
-                    guard continuation != nil else { fatalError("Should have a continuation here") }
                     continuation?.resume()
                     guard !Task.isCancelled else {
                         throw PublisherError.cancelled

Sources/FreeCombine/Publishers/Zipped.swift

@@ -23,7 +23,6 @@ public func Zipped<Left, Right>(
 }
 
 public func zip<Left, Right>(
-    onStartup: UnsafeContinuation<Void, Never>? = .none,
     onCancel: @escaping () -> Void = { },
     _ left: Publisher<Left>,
     _ right: Publisher<Right>