package Ġme . dig i . saas . features . read raw . view model Ċ Ċ import Ġandroidx . lifecycle . ViewModel Ċ import Ġio . reactivex . rx java 3 . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . rx java 3 . kotlin . subscribe By Ċ import Ġio . reactivex . rx java 3 . schedul ers . Schedulers Ċ import Ġkotlinx . coroutines . flow . Mutable State Flow Ċ import Ġkotlinx . coroutines . flow . State Flow Ċ import Ġme . dig i . saas . use cases . Get Raw Session Data UseCase Ċ import Ġme . dig i . saas . utils . Resource Ċ import Ġme . dig i . sdk . entities . File ListItem Ċ Ċ class ĠRead Raw ViewModel ( private Ġval Ġget FileList : ĠGet Raw Session Data UseCase ) Ġ: ĠViewModel () Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġ_ state : ĠMutable State Flow < Resource < List < File ListItem >>> Ġ= ĊĠĠĠĠĠĠĠ ĠMutable State Flow ( Resource . Loading ()) ĊĠĠĠ Ġval Ġstate : ĠState Flow < Resource < List < File ListItem >>> ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġ_ state ĊĊĠĠĠ Ġinit Ġ{ ĊĠĠĠĠĠĠĠ ĠgetData () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun ĠgetData () Ġ{ ĊĠĠĠĠĠĠĠ Ġget FileList ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. invoke () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe By ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠonSuccess Ġ= Ġ{ Ġ_ state . value Ġ= ĠResource . Success ( it . file List ) Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠonError Ġ= Ġ{ Ġ_ state . value Ġ= ĠResource . Failure ( it . localized Message ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ċ }