Designed to handle not only data retrieval but also data mutations. Manages the complexities associated with data synchronization between local and remote sources, conflict resolution, and offline support.
stream
write
clear
clearAll
WriteRequestQueue<Key, Output, *>
). This queue holds pending write operations that need to be synchronized with the remote data source. New write requests are added to the queue. Upon successful synchronization, processed requests are removed.
Initialization
Eager Conflict Resolution
Data Retrieval
Request Queueing
Local Update
Server Synchronization Attempt
Handling the Updater Result
Success
Failure
Response Emission