From 662c974956f7e8f949e5ab9d5ba18d56efe5a1b3 Mon Sep 17 00:00:00 2001
From: Thanh Le <lenguyenthanh@hotmail.com>
Date: Sat, 16 Apr 2016 15:51:36 +0700
Subject: [PATCH] Add example for FunctionSubscriber class

---
 src/examples/kotlin/rx/lang/kotlin/examples/examples.kt | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/examples/kotlin/rx/lang/kotlin/examples/examples.kt b/src/examples/kotlin/rx/lang/kotlin/examples/examples.kt
index 3b0bbbe..b9aecfa 100644
--- a/src/examples/kotlin/rx/lang/kotlin/examples/examples.kt
+++ b/src/examples/kotlin/rx/lang/kotlin/examples/examples.kt
@@ -34,6 +34,10 @@ fun main(args: Array<String>) {
     combineLatest(listOfObservables())
 
     zip(listOfObservables())
+
+    simpleObservable().subscribe(FunctionSubscriber<String>()
+            .onNext { s -> println("1st onNext => $s") }
+            .onNext { s -> println("2nd onNext => $s") })
 }
 
 private fun URL.toScannerObservable() = observable<String> { s ->
@@ -92,4 +96,6 @@ fun combineLatest(observables: List<Observable<String>>) {
 
 fun zip(observables: List<Observable<String>>) {
     observables.zip { it.reduce { one, two -> one + two } }.subscribe { println(it) }
-}
\ No newline at end of file
+}
+
+fun simpleObservable(): Observable<String> = (0..17).toObservable().map { "Simple $it" }
\ No newline at end of file