「 RxJava 101 Concept 」จากงาน Droidcon Bkk งานจบแต่ความรู้ไม่จบ

เนื่องจากมีคนสรุปงานกันไปเยอะและ 555 เราขอแหวกแนวเลือกซัก 1 เรื่องมาเจาะกันไปเลยจะมีทั้งความรู้ของ speaker และส่วนของเจ้าของบล็อครวมกันไปด้วยเลย น่าจะครบสำหรับ 101 (มั้ง) ไว้เอาไปต่อยอดใช้กัน 😎 เราเลยขอตั้งชื่อบทความนี้ว่า

RxJava 101 Concept

ซึ่ง speaker หลักคนที่พูดเรื่องนี้คือ

ซึ่งมันมีปัญหาหลักๆคือ

1. การทำ chain method ค่อนข้างลำบาก ไม่งั้นต้องลงเอยด้วย callback ทำให้มันเริ่มเยอะขึ้นเรื่อยๆ โค๊ดก็รกรุงรังอีก
2. ดัก error ลำบากต้องมานั่ง review โค๊ดว่ามีโอกาสที่จะเกิด error ในส่วนไหนบ้าง
3. ถ้าต้องการยิงการทำงานไปที่ background task ต้องสร้าง Asyntask นู่นนั่นนี่เต็มไปหมด ค่อนข้างลำบากเลยทีเดียว

ซึ่ง RxJava ตอบโจทย์เรื่องพวกนี้ได้เป็นอย่างดีที่สำคัญโค๊ด clean ขึ้นเยอะ และยังทำอะไรที่มากกว่าการ get ค่าธรรมดาๆได้อีกเยอะมาก

Main Concept

แต่การที่จะใช้ RxJava ได้ ในโลกของ Rx เราต้องมองทุกอย่างเป็น data steam ซึ่งจะทำอย่างนั้นได้เราต้อง “หุ้ม” ข้อมูลด้วย Observable เสียก่อน เพื่อให้ข้อมูลมีลักษณะเป็น data steam ก่อน

Rx จึงมี method ที่สร้างตัว Observable มากมายซะเหลือเกิน 😅 ซึ่งเราเรียกมันว่า Operator ข้อดีคือเราสามารถใช้ operator ต่อกันได้มากกว่า 1 operator เช่น

Observable
   .fiter(...)
   .flatMap(...)
   .reduce(...);

และ operator ไม่ได้มีไว้หุ้มข้อมูลอย่างเดียวนะ แต่ละ operator มันมีหน้าที่ของมันด้วยเราต้องเข้าใจก่อนใช้ เช่น

Observable.filter(article -> article.name); //lambda syntax

filter เฉพาะตัวแปรชื่อ name ออกมาเป็น Observable<String> เพื่อเอาไปใช้ต่อ

NOTE: แต่ไม่ต้องห่วงเพราะหลักๆ basic เราใช้กันอยู่ไม่กี่ตัว

จาก 3 วิธีเหลือแค่ 1 วิธีในการ get ค่าบางอย่างออกมา แค่ต้องทำให้มันเป็น Observable ก่อน

เวลาเราเรียก Observable.subscribe(…) (ในที่นี้คือ article( ).subscriber(…) เพราะ article( ) return เป็น observable ออกมา) การทำงานต่างๆจะเริ่ม execute ณ ตอนที่เราเริ่ม subscribe นะ แล้วเราจะได้ Subscription ออกมาด้วยเป็น object ที่เก็บ state ต่างๆของการ subscribe ตอนนั้นๆ

เสร็จแล้วข้อมูลจะเริ่มถูก emit จาก observable แล้วเข้า onNext(…) ไปเรื่อยๆจนครบ onCompleted( ) จะถูกเรียก ถ้าในระหว่างนั้นมีการเกิด error ขึ้นไม่ว่ากรณีใดๆจะเข้า onError(…) ให้ทันทีง่ายต่อการ handle

NOTE: จะเห็นว่า concept คล้าย loop วนไปเรื่อยๆเนาะ

เผื่อจะงงกันเราขอวาดเป็นแผนภาพดังนี้

NOTE: จากโค๊ดข้างบนเวลาเราใช้ Rx ใน android lifecycle เราควร s.unsubscribe( ) ทิ้งทุกครั้งเพื่อกัน Memory leak

Document

รูปข้างบนอธิบายวิธีอ่าน Document ว่าแต่ละอย่างมันคืออะไร

ให้ง่ายไปอีกมีคนทำ app สำหรับดูตัวอย่าง Rx ด้วยนะ

แนะนำให้ Download ติดไว้อ่านเวลาว่างๆแทนการเล่น facebook เนาะ 👍

เป็นเว็บก็มีนะ

Example in Real world

วิธี create observable แบบง่ายๆ

อันดับแรกเราต้องโยน Observable<ArticleQuantity> เข้ามาใน method ก่อน

เสร็จแล้วเริ่ม filter → เป็น operator ใช้ filter ค่าต่างๆออกมาอันนี้ตรงไปตรงมาก read more

ในส่วนนี้เรา filter เฉพาะตัวแปร isInStock คือสินค้ายังมี stock อยู่ เสร็จแล้วเราจะได้ Observable<String> เพื่อเอาไป groupBy ต่อ

groupBy → เป็น operator ใช้สร้าง group ของ observable read more

ในส่วนนี้มี articleIdFromTag(String) เพื่อรวม article ที่มี TagId เดียวกันไว้ใน observable ตัวเดียว ซึ่งสุดท้ายเราจะได้ group ของ observable ไปใช้ต่อใน flatMap

flatMap → read more

ในส่วนนี้เราใช้ flatMap เพื่อเริ่มนับจำนวน article ในแต่ละ group ที่ได้มาจาก groupBy

map → เป็น operator ที่เราสามารถใช้ map ค่าต่างๆตามที่เราต้องการ read more

ในที่นี้เราต้องการแปลงให้เป็น ArticleQuantity ก่อน

reduce → read more

ในส่วนนี้เราจะเริ่ม sum ทุกๆ article ในแต่ละ group และ สร้างเป็น new ArticleQuantity( … , … ) ใหม่ 1 group/ArticleQuantity

จะทำอย่างนี้ไปเรื่อยๆจนครบทุก list เราจะได้เป็น Observable<ArticleQuantity> แยกตาม TagId พร้อมจำนวนที่เรานับ ไปใช้งานต่อได้แว้ววว

มันอาจจะดูงงๆอยู่บ้าง แนะนำให้ทำความเข้าใจให้ได้เนาะ

Schedulers (threading)

ในโลกของ Rx เราสามารถยิงการทำงานต่างๆไป background thead ได้ง่ายมาก ทำให้เราไม่จำเป็นต้องใช้ AyncTask หรือ Thread.start( ) อีกต่อไป

    
    .subscribeOn(Schedulers.id())
    
    

.observeOn(AndroidSchedulers.mainThread())
    .flatMap(...);

NOTE: มีประโยนช์มากกับการทำงานบางอย่างที่ทำงานบน UiThread ไม่ได้เราต้องยิงไป background ก่อนแล้วค่อยกลับมา update UI

Tips

ถ้าเกิดกรณีที่มี chain operator เยอะๆแบบ 4 5 ตัวต่อกัน แนะนำให้สร้าง method มาครอบเพื่อให้ง่ายต่อการทำความเข้าใจครับ