Merge pull request ReactiveX#76 from carlosypunto/subjects-playground

Subjects playground

Author: kzaher

Playgrounds/Subjects.playground/Contents.swift

@@ -0,0 +1,69 @@
+import Cocoa
+import RxSwift
+
+/*:
+
+To use playgrounds please open Rx.xcworkspace, build RxSwift-OSX scheme and then open playgrounds in Rx.xcworkspace tree view.
+
+*/
+
+func writeSequenceToConsole(name: String, sequence: Observable<String>) {
+    sequence
+        >- subscribeNext {
+            println("Subscription: \(name), value: \($0)")
+        }
+}
+
+
+/*:
+
+## PublishSubject
+
+PublishSubject can begin emitting items immediately upon creation, but there is a risk that one or more items may be lost between the time the Subject is created and the observer subscribes to it.
+
+*/
+example("PublishSubject") {
+    let subject = PublishSubject<String>()
+    writeSequenceToConsole("1", subject)
+    sendNext(subject, "a")
+    sendNext(subject, "b")
+    writeSequenceToConsole("2", subject)
+    sendNext(subject, "c")
+    sendNext(subject, "d")
+}
+
+
+/*:
+
+## ReplaySubject
+
+ReplaySubject emits to any observer all of the items, in the buffer, that were emitted by the source 
+
+*/
+example("ReplaySubject") {
+    let subject = ReplaySubject<String>(bufferSize: 1)
+    writeSequenceToConsole("1", subject)
+    sendNext(subject, "a")
+    sendNext(subject, "b")
+    writeSequenceToConsole("2", subject)
+    sendNext(subject, "c")
+    sendNext(subject, "d")
+}
+
+
+/*:
+
+## BehaviorSubject a.k.a. Variable
+
+ReplaySubject emits to any observer all of the items, in the buffer, that were emitted by the source 
+
+*/
+example("ReplaySubject") {
+    let subject = BehaviorSubject(value: "z")
+    writeSequenceToConsole("1", subject)
+    sendNext(subject, "a")
+    sendNext(subject, "b")
+    writeSequenceToConsole("2", subject)
+    sendNext(subject, "c")
+    sendNext(subject, "d")
+}

Playgrounds/Subjects.playground/Sources/SupportCode.swift

@@ -0,0 +1,6 @@
+
+
+public func example(description: String, action: () -> ()) {
+    println("\n--- \(description) example ---")
+    action()
+}

Playgrounds/Subjects.playground/contents.xcplayground

@@ -0,0 +1,4 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<playground version='5.0' target-platform='osx' requires-full-environment='true' display-mode='rendered'>
+    <timeline fileName='timeline.xctimeline'/>
+</playground>