Swiftpack.co - Package - RxSwiftCommunity/RxTask


An RxSwift implementation of a command line task runner.

GitHub release Build Status codecov docs carthage compatible swift package manager compatible platform macOS language swift 3.0

Linux Compatibility

Currently, RxTask does not support Linux. RxTask relies on some functionality in Foundation that is currently not available in the Linux port. This will be re-evaluated after the Swift 3.1 release. PRs in this area are quite welcome! 👍



github "RxSwiftCommunity/RxTask"


import PackageDescription

let package = Package(
    name: "YOUR_PROJECT_NAME",
    targets: [],
    dependencies: [
        .Package(url: "https://github.com/RxSwiftCommunity/RxSwift.git", majorVersion: 0)


Create A Task

Creating a task is as simple as providing a launchPath to the executable.

let task = Task(launchPath: "/bin/ls")

Optionally, you can provide arguments, a workingDirectory, and an environment.

let task = Task(launchPath: "/bin/echo", arguments: ["$MESSAGE"], environment: ["MESSAGE": "Hello World!"])

Launch A Task

Tasks can be launched with the launch() method. This produces a self-contained process. This means the same task can be launch()ed multiple times producing separate processes.


The output of launch() is a Observable<TaskEvent>. TaskEvent is an enum that is used to report significant events in the task lifetime. The possible events are:

  • launch(command: String)
  • stdOut(Data)
  • stdErr(Data)
  • exit(statusCode: Int)

Note: Currently an event is only considered successful if it exits with a statusCode of 0. Other exit statuses will be considered a TaskError.


If you create a task that expects input, you can provide an Observable<Data> for stdin when you are launch()ing the Task. Data will be written to stdin as soon as it is emitted by the Observable.

Filtering TaskEvents

If you are only concerned with whether a Task has completed successfully, you can use the built-in operator justExitStatus().

Task(launchPath: "/bin/ls").launch()
    .subscribe(onNext: { exitStatus in /* ... */ })
    .disposed(by: disposeBag)

Alternatively, if you are only interested in the output of a Task, you can use the operator justOutput(). This will send the output of both stdout and stderr.

Task(launchPath: "/bin/ls").launch()
    .subscribe(onNext: { output in /* ... */ })
    .disposed(by: disposeBag)


TaskError is an Error that will be emitted under the following situations:

  • uncaughtSignal: The Task terminated with an uncaught signal (e.g. SIGINT).
  • exit(statusCode: Int): The Task exited with a non-zero exit code.

API Reference

Full docs can be found here.


Stars: 11
Help us keep the lights on


Used By

Total: 0


0.2.0 - Feb 24, 2017


  • stdin, stdout, and stderr are now treated as raw Data. Encoding/Decoding is left to the user.
  • stdin is now available when launching a Task.
  • Task conforms to CustomStringConvertible and Equatable.
Bug Fixes
  • None

0.1.0 - Feb 21, 2017

Initial release.