در برنامه نویسی واکنشی (reactive programming) به جای داده (data) جریانی از داده (data flows) را داریم. به جریان داده stream هم گفته می شود.
به استریم قبل از اعمال اپراتور upStream و به استریم بعد از اعمال اپراتور downStream گفته می شود. شکل زیر:
در برنامه نویسی واکنشی (reactive programming) به جای داده (data) جریانی از داده (data flows) را داریم. به جریان داده stream هم گفته می شود.
به استریم قبل از اعمال اپراتور upStream و به استریم بعد از اعمال اپراتور downStream گفته می شود. شکل زیر:
کتابخانه RxBinding یک کتابخونه برای تبدیل ویوهای اندروید به Observable هست.
مثال هایی از نحوه استفاده این کتابخانه:
RxJava دارای سه عنصر اصلی است:
1. Observable: مسئول منتشر کردن آیتم ها
2. Subscriber: مصرف کننده آیتم های منتشر شده توسط Observable
3. Schedulers: در واقع همون thread pool هست که برای انجام تسک ها ازش استفاده میشه
فلوی اجرای کدهای RxJava به این صورت هست:
اول Observable ساخته میشه، سپس Subscriber (یا همون observable) بهش متصل میشه، پس از آن با توجه به تردی که در subscribeOn مشخص شده، عملیات اپراتورها در آن ترد انجام شده و در نهایت، با توجه به تردی که توسط observeOn معرفی می گردد، در ترد مذکور منتشر می شود.
بنابراین دیتای Observable هنگامی که observer به آن متصل می شود، ارزیابی می گردد. اما در اپراتورهای just و from به این صورت نیست و دیتای observable در لحظه ای که دیتا ساخته می شود، ارزیابی خواهد شد.