Android Live Objects/Collections
Live Objects are supported in the Android SDK with RxJava Data Streaming
Last updated
Was this helpful?
Live Objects are supported in the Android SDK with RxJava Data Streaming
Last updated
Was this helpful?
The library is being used in Android development to achieve Live Object and Live Collection behavior.
It is a Java VM implementation of ReactiveX, a library for composing asynchronous and event-based programs by using observable sequences. The building blocks of RxJava are Observables and Subscribers. Observable is used for emitting items and Subscriber is used for consuming those items.
You can visit for more information.
SDK handles lots of data received from various sources. Data can be present in local cache. It might also be queried from the server or received from some real-time events. What this means is that same data is constantly updating. The data that you are accessing at the moment can get updated by other sources and becomes out of sync.
Rx3 Data Stream helps in syncing the data so you will always get the most recent one. Whenever the data updates, you will be notified through Flowable Objects and Flowable Collection.
New data gets automatically collected everytime when there is an updation and user need not refresh to get the recent data.
Live Collection is available for the following functionalities in user/community feeds via pagingData APIs:
Post Collection
Comment Collection
Reactions Collection
Followers/Following Collection
Channel Collection
Message Collection
Channel Member Collection
Community Collection
Community Members Collection
User list collection
Channel members search collection
Live stream collection
To retrieve data from the RxStream, we need to subscribe to the Stream(Flowable/Single/Completable) by defining subscribing and observing threads.
In the RxJava3 framework we have these different types of objects that can be observed:
Flowable - emits a stream of elements
doOnNext
doOnError
Single - emits exactly one element
doOnSuccess
doOnError
Completable - emits a “complete” event, without emitting any data type, just a success/failure
doOnComplete
doOnError
To get channel data, below is a sample code.
The Amity Android SDK comes equipped with asynchronous and data stream capabilities, powered by RxJava3 by default. However, for those who prefer to use Kotlin's Coroutines, the SDK can be seamlessly integrated with the following Kotlin extension functions, allowing for easy interoperability between Amity Android SDK functions and Kotlin Coroutines functions.
By using the .await() method, it enables the conversion of Completable and Single<T> functions of the Amity Android SDK into suspend functions.
By using the .asFlow() method, it enables the conversion of Flowable<T> functions of the Amity Android SDK into Flow functions.
Amity Android SDK seamlessly integrates with Jetpack Compose UI, allowing you to take full advantage of the modern UI toolkit provided by Jetpack Compose. You can effortlessly incorporate our SDK into your Jetpack Compose-based projects to enhance your app's social experience. This compatibility ensures that you can leverage the power of Jetpack Compose while benefiting from the features and capabilities our SDK provides.
In Jetpack Compose, integrating data from a `Flow<PagingData<T>>` source into your UI is made easy through the `collectAsLazyPagingItems()` function. This function allows you to seamlessly paginate and display items within your Composable functions.
To start using it, add compose paging dependency in your project app level build.gradle file.
Then in your Composable functions, you can collect from flow and display data, and also can observe the load state.
By using collectAsState() method, it can deliver asynchronous data updates to your Compose UI components.
Data Stream uses all standard .