Добавлены примеры работы с subjects

Author: Mikhail Valuyskiy

app/src/test/java/ru/androidschool/rxjava/kotlin/subjects/AsyncSubjectDemo.kt

@@ -0,0 +1,28 @@
+package ru.androidschool.rxjava.kotlin.subjects
+
+import io.reactivex.subjects.AsyncSubject
+import io.reactivex.subjects.Subject
+import org.junit.Test
+
+class AsyncSubjectDemo {
+
+    @Test
+    fun asyncSubjectdDemo() {
+        val subject: Subject<String> = AsyncSubject.create()
+
+        subject.subscribe(
+            { s -> println("Observer 1: $s") },
+            { e -> e.printStackTrace() }
+        ) { println("Observer 1 done!") }
+
+        subject.onNext("Alpha")
+        subject.onNext("Beta")
+        subject.onNext("Gamma")
+        subject.onComplete()
+
+        subject.subscribe(
+            { s -> println("Observer 2: $s") },
+            { e: Throwable -> e.printStackTrace() }
+        ) { println("Observer 2 done!") }
+    }
+}

app/src/test/java/ru/androidschool/rxjava/kotlin/subjects/BehaviorSubjectDemo.kt

@@ -0,0 +1,21 @@
+package ru.androidschool.rxjava.kotlin.subjects
+
+import io.reactivex.subjects.BehaviorSubject
+import io.reactivex.subjects.Subject
+import org.junit.Test
+
+class BehaviorSubjectDemo {
+
+    @Test
+    fun behaviorSubjectdDemo() {
+        val subject: Subject<String> = BehaviorSubject.create()
+
+        subject.subscribe { s -> println("Observer 1: $s") }
+
+        subject.onNext("Alpha")
+        subject.onNext("Beta")
+        subject.onNext("Gamma")
+
+        subject.subscribe { s -> println("Observer 2: $s") }
+    }
+}

app/src/test/java/ru/androidschool/rxjava/kotlin/subjects/PublishSubjectDemo.kt

@@ -0,0 +1,21 @@
+package ru.androidschool.rxjava.kotlin.subjects
+
+import io.reactivex.subjects.PublishSubject
+import io.reactivex.subjects.Subject
+import org.junit.Test
+
+class PublishSubjectDemo {
+
+    @Test
+    fun publishSubjectDemo() {
+        val subject: Subject<String> = PublishSubject.create()
+
+        subject.subscribe { x -> println(x) }
+
+        subject.onNext("1")
+        subject.onNext("2")
+        subject.onNext("3")
+
+        subject.onComplete()
+    }
+}

app/src/test/java/ru/androidschool/rxjava/kotlin/subjects/ReplaySubjectDemo.kt

@@ -0,0 +1,23 @@
+package ru.androidschool.rxjava.kotlin.subjects
+
+import io.reactivex.subjects.ReplaySubject
+import io.reactivex.subjects.Subject
+import org.junit.Test
+
+class ReplaySubjectDemo {
+
+    @Test
+    fun replaySubjectdDemo() {
+        val subject: Subject<String> = ReplaySubject.create()
+
+        subject.subscribe { s -> println("Observer 1: $s") }
+
+        subject.onNext("Alpha")
+        subject.onNext("Beta")
+        subject.onNext("Gamma")
+
+        subject.onComplete()
+        // Здесь подписываемся еще раз и получаем все переданные события
+        subject.subscribe { s -> println("Observer 2: $s") }
+    }
+}

app/src/test/java/ru/androidschool/rxjava/kotlin/subjects/UnicastSubject.kt

@@ -0,0 +1,32 @@
+package ru.androidschool.rxjava.kotlin.subjects
+
+import io.reactivex.Observable
+import io.reactivex.subjects.Subject
+import io.reactivex.subjects.UnicastSubject
+import org.junit.Test
+import java.util.concurrent.TimeUnit
+
+class UnicastSubject {
+
+    @Test
+    fun unicastcSubjectdDemo() {
+        val subject: Subject<String> = UnicastSubject.create()
+        
+        Observable.interval(300, TimeUnit.MILLISECONDS)
+            .map { l: Long -> ((l + 1) * 300).toString() + " milliseconds" }
+            .subscribe(subject)
+
+        sleep(2000)
+        subject.subscribe { s -> println("Observer 1: $s") }
+        sleep(2000)
+    }
+
+    fun sleep(millis: Long) {
+        try {
+            Thread.sleep(millis)
+        } catch (e: InterruptedException) {
+            e.printStackTrace()
+        }
+    }
+
+}