Estoy trabajando en una aplicación de chat con arquitectura MVVM y uso SharedFlow para transferir mensajes entrantes del Repository a ViewModel . Cuando el usuario está desconectado y otro usuario le envía una gran cantidad de mensajes, tan pronto como el usuario está en línea, los mensajes se reciben uno tras otro en el Repository y deben transferirse a ViewModel para mostrarlos en la interfaz de usuario. . Primero establecí el valor de extraBufferCapacity en 1 y vi que en este caso solo se reciben los dos primeros mensajes en ViewModel . Luego aumenté el valor de extraBufferCapacity a 6 y vi que los primeros 7 mensajes se transmitieron a ViewModel . Ahora, si aumento el valor de extraBufferCapacity a Int.MAX_VALUE , ¿provocará una pérdida de memoria?

Repositorio:

 object ChatRepo { private val _receiveMessageFlow = MutableSharedFlow<Message>(extraBufferCapacity = Int.MAX_VALUE) val receiveMessageFlow = _receiveMessageFlow.asSharedFlow() fun listen(socket: Socket) { socket.on(Config.ON_PV_MESSAGE, onPvMessage) } private val onPvMessage = Emitter.Listener { args -> val message = Gson().fromJson(args[0].toString(), Message::class.java) _receiveMessageFlow.tryEmit(message) } }

Ver modelo:

 class ChatViewModel(var receiver: User) : ViewModel() { private val _messagesLive = MutableLiveData<Resource<MessageList>>() val messagesLive = _messagesLive as LiveData<Resource<MessageList>> init { observeReceivedMessage() } private fun observeReceivedMessage() { viewModelScope.launch { ChatRepo.receiveMessageFlow.collect { message -> if (message.senderUid == receiver.uid) { addMessage(message) } } } } private fun addMessage(message: Message) { val resource = _messagesLive.value ?: Resource.success(MessageList()) val messageList = resource.data ?: MessageList() messageList.addMessageLast(message) _messagesLive.value = Resource.add(messageList, 0) } }