back to home

amitshekhariitbhu / RxJava2-Android-Samples

RxJava 2 Android Examples - How to use RxJava 2 in Android

4,928 stars
1,054 forks
17 issues
Java

AI Architecture Analysis

This repository is indexed by RepoMind. By analyzing amitshekhariitbhu/RxJava2-Android-Samples in our AI interface, you can instantly generate complete architecture diagrams, visualize control flows, and perform automated security audits across the entire codebase.

Our Agentic Context Augmented Generation (Agentic CAG) engine loads full source files into context on-demand, avoiding the fragmentation of traditional RAG systems. Ask questions about the architecture, dependencies, or specific features to see it in action.

Source files are only loaded when you start an analysis to optimize performance.

Embed this Badge

Showcase RepoMind's analysis directly in your repository's README.

[![Analyzed by RepoMind](https://img.shields.io/badge/Analyzed%20by-RepoMind-4F46E5?style=for-the-badge)](https://repomind.in/repo/amitshekhariitbhu/RxJava2-Android-Samples)
Preview:Analyzed by RepoMind

Repository Overview (README excerpt)

Crawler view

Learning RxJava 2 for Android by example This project is for : • who is migrating to RxJava 2 • or just started with RxJava. About me Hi, I am Amit Shekhar, Founder @ Outcome School • IIT 2010-14 • I have taught and mentored many developers, and their efforts landed them high-paying tech jobs, helped many tech companies in solving their unique problems, and created many open-source libraries being used by top companies. I am passionate about sharing knowledge through open-source, blogs, and videos. Follow Amit Shekhar • X/Twitter • LinkedIn • GitHub Follow Outcome School • YouTube • X/Twitter • LinkedIn • GitHub I teach at Outcome School • AI and Machine Learning • Android Join Outcome School and get a high-paying tech job: Outcome School Just Build the project and start learning RxJava by examples. RxJava 2.0 has been completely rewritten from scratch on top of the Reactive-Streams specification. The specification itself has evolved out of RxJava 1.x and provides a common baseline for reactive systems and libraries. Using RxJava 2.0 Library in your application Add this in your build.gradle If you are using RxAndroid also, then add the following RxJava 2 Operators Examples present in this sample project: • -> transform the items emitted by an Observable by applying a function to each item. Blog: RxJava Operator Map vs FlatMap • -> combine the emissions of multiple Observables together via a specified function and emit single items for each combination based on the results of this function • -> emit only those items from an Observable that pass a predicate test • -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable. Blog: RxJava Operator Map vs FlatMap • -> emit only the first n items emitted by an Observable. Blog for reference • -> apply a function to each item emitted by an Observable, sequentially, and emit the final value • -> suppress the first n items emitted by an Observable • -> periodically gather items emitted by an Observable into bundles and emit these bundles rather than emitting the items one at a time • -> emit the emissions from two or more Observables without interleaving them. Blog for reference • -> ensure that all observers see the same sequence of emitted items, even if they subscribe after the Observable has begun emitting items • -> combine multiple Observables into one by merging their emissions • -> transform the items emitted by an Observable into Observables, and mirror those items emitted by the most-recently transformed Observable Highlights of the examples : • DisposableExampleActivity - Using . Blog for reference • FlowableExampleActivity - Using and operator • SingleObserverExampleActivity - Using • CompletableObserverActivity - Using • MapExampleActivity - Using Operator. Blog: RxJava Operator Map vs FlatMap • ZipExampleActivity - Using Operator • BufferExampleActivity - Using Operator • TakeExampleActivity - Using Operator. Blog for reference • ReduceExampleActivity - Using Operator • FilterExampleActivity - Using Operator • SkipExampleActivity - Using Operator • ReplayExampleActivity - Using Operator • ConcatExampleActivity - Using Operator. Blog for reference • MergeExampleActivity - Using Operator • DeferExampleActivity - Using Observable • SwitchMapExampleActivity - Using Observable • IntervalExampleActivity - Using . Blog for reference • RxBusActivity - RxBus, RxJava2Bus, EventBus, RxEventBus • PaginationActivity - Pagination for loadMore in RecyclerView. Blog: Pagination In RecyclerView Using RxJava Operators • ComposeOperatorExampleActivity - Compose operator for reusable • Search Implementation - Using , , • Implement Caching Using RxJava Operators - Using , • PublishSubjectExampleActivity. Blog: RxJava Subject - Publish, Replay, Behavior, and Async Find this project useful ? :heart: • Support it by clicking the :star: button on the upper right of this page. :v: Thanks **Amit Shekhar**\ Co-Founder @ Outcome School You can connect with me on: • Twitter • LinkedIn • GitHub • Facebook **Read all of our blogs here.** License Contributing to RxJava 2 Android Samples Just make pull request. You are in!