Salimov Azimjon 316-18 guruh Mavzu: Android dasturlarida xabarlarni yuborish va almashtirish uchun foydalanuvchi interfeysini yaratish

}.flow
}

override fun searchStock(query: String) = flow>> {

searchService.searchStock(query)
.collect {
when (it) {
is Resource.InitialState ->{
emit(Resource.InitialState())
}
is Resource.Loading -> {
emit(Resource.Loading())
}
is Resource.Error -> {
emit(Resource.Error(it.message.toString()))
}
is Resource.Success -> {
it.data?.let { response ->
emit(Resource.Success(response.result))
}
}
}
}
}
}

package uz.azim.stocks.ui.fragment.stocks.vm

import androidx.lifecycle.viewModelScope
import androidx.paging.PagingData
import androidx.paging.cachedIn
import androidx.paging.map
import com.google.gson.Gson
import dagger.hilt.android.lifecycle.HiltViewModel
import kotlinx.coroutines.flow.MutableStateFlow
import kotlinx.coroutines.flow.asStateFlow
import kotlinx.coroutines.flow.collectLatest
import kotlinx.coroutines.launch
import okhttp3.*
import uz.azim.stocks.data.repo.stock.StocksRepository
import uz.azim.stocks.model.Quote
import uz.azim.stocks.model.StockUpdate
import uz.azim.stocks.ui.BaseViewModel
import uz.azim.stocks.util.Resource
import uz.azim.stocks.util.log
import javax.inject.Inject

@HiltViewModel

class StocksVM
@Inject constructor(
private val stocksRepository: StocksRepository
) : BaseViewModel() {

private val _quotes = MutableStateFlow
>>(Resource.InitialState())
val quotes = _quotes.asStateFlow()

private val _stockUpdate = MutableStateFlow>(Resource.InitialState())

val stockUpdate = _stockUpdate.asStateFlow()

private val stocks = arrayListOf()

lateinit var ws: WebSocket

init {
getStocks()

}

fun getStocks() = viewModelScope.launch(exceptionHandler) {

stocksRepository.getStocks()
.cachedIn(viewModelScope)
.collectLatest {
log("collect")
_quotes.value = Resource.Success(it)