Example: RxSwift.

Author: zachgrayio

Package.swift

@@ -12,13 +12,12 @@ let package = Package(
  )
  ],
  dependencies: [
- //example:
- // .package(url: "https://github.com/ReactiveX/RxSwift.git", "4.0.0" ..< "5.0.0")
+ .package(url: "https://github.com/ReactiveX/RxSwift.git", "4.0.0" ..< "5.0.0")
  ],
  targets: [
  .target(
  name: "STSLibrary",
- dependencies: []),
+ dependencies: ["RxSwift"]),
  .target(
  name: "STSApplication",
  dependencies: ["STSLibrary"]),

Sources/STSLibrary/Application.swift

@@ -7,5 +7,7 @@ public final class Application {
 
  public func run() throws {
  print("\(prefix): \(TensorFlowExample.multiplyTensor())")
+ print("\(prefix): Running RxExample:")
+ RxExample.printHello()
  }
 }

Sources/STSLibrary/RxExample.swift

@@ -0,0 +1,19 @@
+
+import RxSwift
+import Foundation
+
+struct RxExample {
+ static func printHello() {
+ let wordList = ["Hello", "Rx", "World"]
+
+ _ = Observable<Int>.interval(1, scheduler: SerialDispatchQueueScheduler(qos: .default))
+ .take(wordList.count)
+ .map { index in wordList[index]}
+ .do(onNext: { word in
+ print(word)
+ })
+
+ // sleep for the duration of the above so the application doesn't exit before completion
+ Thread.sleep(forTimeInterval: Double(wordList.count))
+ }
+}