स्टोर का फिर से खोलना: कोरटाइन का उपयोग करके एंड्रॉइड में डेटा लोड करना

^{मैं आपका ध्यान माइक नखिमोविच के मूल लेख के अनुवाद पर लाता हूँ}

एक बार, मैंने न्यूयॉर्क टाइम्स में काम किया और एक पुस्तकालय बनाया Store, जिसका नाम था "आसान, उत्तरदायी डेटा लोड करने के लिए जावा पुस्तकालय।" हमने अमरूद के कैशRxJava के कार्यान्वयन से लिए गए टेम्पलेट्स का उपयोग करके स्टोर बनाया । आज के ऐप उपयोगकर्ता यूआई में पुल-टू-रिफ्रेश जैसे काम किए बिना डेटा अपडेट होने की उम्मीद करते हैंआगे और पीछे स्क्रीन के बीच डेटा ताज़ा करने या स्थानांतरित करने के लिए। प्रतिक्रियाशील दृश्यपटल ने मुझे यह सोचने पर मजबूर किया कि कैसे हम साधारण एपीआई के साथ घोषणात्मक डेटा गोदाम हो सकते हैं जो कि मल्टीटास्क थ्रॉटलिंग और डिस्क कैशिंग जैसे जटिल जटिल कार्य हैं, जो आधुनिक मोबाइल अनुप्रयोगों में आवश्यक हैं। अपने तीन वर्षों के संचालन में, स्टोर में 45 योगदानकर्ता हैं और 3,500 से अधिक गीथहब सितारे हैं। अब से, मैं घोषणा की थी कि खुश हूँ ड्रॉपबॉक्स स्टोर के सक्रिय विकास पर ले जाएगा और के लिए समर्थन के साथ Kotlin पर यह पूरी तरह से जारी करेंगे Coroutinesऔर Flow। और अब Store 4- यह एंड्रॉइड पारिस्थितिकी तंत्र की एपीआई और वर्तमान आवश्यकताओं को पुनर्विचार करके हमने जो कुछ भी सीखा है, उसका लाभ उठाने का एक अवसर है।

Android . . , , Google. , Android. Android Jetpack:

, Android Jetpack :

https://developer.android.com/jetpack/docs/guide

• :  , AndroidX , Lifecycle Scopes . , view- .
• View Model Live Data:  , , ( , !).
• Room:  SQLite, ORM RxJava .
• Remote Data Source:  Jetpack, Retrofit Okhttp Square .

, , , ( , , Jetpack ;-) ). , . , Dropbox Store, , .

, Store, . ,

«… , , .  , , , ».

. , , , . , .

Store?

, , Store, Android- . — , . , UX. , , . , . Store, .

, , . …

Store :

Store

, , Store, , , .

4 – Android . , . , Room SQLDelight, , . -, push-, Firebase, «» . Store , , , , , . , Store: http://github.com/dropbox/Store.

Store 4 . RxJava , Flow.

, , , , RxJava? . , , . , . , , , , .

— . RxJava - . API RxJava :

// Observable.java
@CheckReturnValue
public final Disposable subscribe(Consumer onNext) {}

, , RxJava Observable Disposable . dispose(), . . RxJava2 @CheckReturnValue— , flowable.subscribe , . , , . , RxJava, .

RxJava , dispose(). . RxJava, , , Kotlin Flow , . , Flow . Flow , .

suspend fun Flow.collect(...)

Collect RxJava, , Flow. RxJava, collect() "suspend". , ( async/await), . Flow.collect , , .

, Android ( ) , , . , Kotlin, , viewModelScope Jetpack, , . , Android: , .

public fun CoroutineScope.launch(...)
 
viewModelScope.launch {
  flow.collect{ handle(it) }
}

, Flow. Android. , AndroidX . , ViewModel, , Room Flow. , (Paging). Store , Android , .

, Store , Android, , , , Kotlin multi-platform, . RxJava Kotlin native/js 6000 .

Store?

Store . Store, Fetcher, , , . , Store . Store Flow, — ! Store // , , .

Store

, Store. , :

StoreBuilder.fromNonFlow { api.fetchSubreddit(it, "10")}
            .persister(
              reader = db.postDao()::loadPosts,
              writer = db.postDao()::insertPosts,
              delete = db.postDao()::clearFeed)
            .cachePolicy(MemoryPolicy)
            .build()

:

• ,
• API , , .

Store  . persister() Store. , Observable, Jetpack Room, SQLDelight Realm.

:

Store


 Store  . , Flow, , ReturnType.

val store = StoreBuilder.from {
                articleId -> api.getArticle(articleId) //Flow<Article>
            }
            .build()

Store , , toString(), equals() hashCode(). Fetcher . . , equals() hashcode() data- Kotlin.

: Stream


API, Store, :

fun stream(request: StoreRequest<Key>):Flow<StoreResponse>Output>>

StoreRequest, , . StoreResponse. StoreResponse — Kotlin, Loading, Data Error. StoreResponse ResponseOrigin, , .

• Loading ResponseOrigin. .
• Data , , Store.
• Error , , ResponseOrigin.

Store , StoreResponse.Error, Flow , , . - , render/updateUI . . :

lifecycleScope.launchWhenStarted {
  store.stream(StoreRequest.cached(key = key, refresh=true)).collect { response ->
    when(response) {
        is StoreResponse.Loading -> showLoadingSpinner()
        is StoreResponse.Data -> {
            if (response.origin == ResponseOrigin.Fetcher) hideLoadingSpinner()
            updateUI(response.value)
        }
        is StoreResponse.Error -> {
            if (response.origin == ResponseOrigin.Fetcher) hideLoadingSpinner()
            showError(response.error)
        }
    }
  }
}

: Store.get(key), Store.stream(key)  Store.fresh(key).

• suspend fun Store.get(key: Key): Value
 — . , .
• suspend fun Store.fresh(key: Key): Value
 — , .
• suspend fun Store.stream(key: Key): Flow
 — (Flow) .

get():

lifecycleScope.launchWhenStarted {
  val article = store.get(key)
  updateUI(article)
}

store.get(key), ( ), . store.get(key) , . ( ) , . , , , Store. Store . Store , , .

 store.fresh(key)  ( ). ,  fresh()  ,  store.get()/stream()  .  fresh()  pull-to-refresh .
 fresh()  get()  .

Stream


, store.stream(key), , , / . stream() , .

lifecycleScope.launchWhenStarted { 
  store.stream(StoreRequest.cached(3, refresh = false)) 
.collect{ }
 
 
store.stream(StoreRequest.get(3)) // ,   
    .collect{  }

, Store . , , , . , . Store.get() 12 . , . .


 Store ,  persister()  . , , Store , , .


 persister(),  Flow  Store  . , ,  Store,   Store.

, Observable (Jetpack Room, SQLDelight Realm), , , UX.

StoreBuilder.fromNonFlow {api.fetchSubreddit(it, "10")}
            .persister(
              reader = db.postDao()::loadPosts,
              writer = db.postDao()::insertPosts,
              delete = db.postDao()::clearFeed)
            .cachePolicy(MemoryPolicy)
            .build()

Store , . , Store (Realm, SQLite, Firebase ..). SQLite Room, Jetpack.

API Store — , . :

• , Room
• (StoreRequest)
• (stream)
• API, Kotlin.

, Store. , , Android, . , -, - . , , .

KotlinConf:

Store : github.com/dropbox/Store

^{, , Android Open Source Project, , Creative Commons 2.5 Attribution License}