WedX - журнал о программировании и компьютерных науках

Совместное использование каналов сопрограмм и конструктора Liveata

Как я могу использовать каналы сопрограмм вместе с построителем сопрограмм Liveata (androidx.lifecycle:lifecycle-livedata-ktx architecture component) для непрерывного прослушивания сообщений, созданных из библиотеки веб-сокетов на ReceiveChannel<String>?

Моя первая мысль - реализовать это так

val user: LiveData<String> = liveData {
    while(true) {
        val data = myWebsocketChannel.receive() //Channel suspend function
        emit(data)
    }
}

Но это кажется немного "не-котлиным", и мое чутье подсказывает мне, что есть способ лучше решить эту проблему. Есть ли лучший способ обработки данных публикации, однажды полученных из канала сопрограмм?


Ответы:


1

Я бы написал это так:

val user: LiveData<User> = liveData {
    myWebsocketChannel.consumeEach { data ->
       emit(data)
   }
}

myWebsocketChannel.consumeEach { ... } будет повторяться бесконечно (приостанавливается, если канал пуст), пока кто-нибудь не закроет myWebsocketChannel. Со стороны производителя - там, где мы слушаем сокет, мы должны быть осторожны, чтобы не закрыть канал преждевременно.

Надеюсь, это поможет :)

03.11.2019
  • Остановится ли это, когда в канале больше не будет элементов в очереди? 03.11.2019
  • Он перестанет работать, если кто-то вызовет channel.close () на другой стороне канала. В противном случае он будет повторяться бесконечно (приостанавливается, если канал пуст). 03.11.2019
  • Новые материалы

    Как создать диаграмму градиентной кисти с помощью D3.js
    Резюме: Из этого туториала Вы узнаете, как добавить градиентную кисть к диаграмме с областями в D3.js. Мы добавим градиент к значениям SVG и применим градиент в качестве заливки к диаграмме с..

    Я хотел выучить язык программирования MVC4, но не мог выучить его раньше, потому что это выглядит сложно…
    Просто начните и учитесь самостоятельно Я хотел выучить язык программирования MVC4, но не мог выучить его раньше, потому что он кажется мне сложным, и я бросил его. Это в основном инструмент..

    Лицензии с открытым исходным кодом: руководство для разработчиков и создателей
    В динамичном мире разработки программного обеспечения открытый исходный код стал мощной парадигмой, способствующей сотрудничеству, инновациям и прогрессу, движимому сообществом. В основе..

    Объяснение документов 02: BERT
    BERT представил двухступенчатую структуру обучения: предварительное обучение и тонкая настройка. Во время предварительного обучения модель обучается на неразмеченных данных с помощью..

    Как проанализировать работу вашего классификатора?
    Не всегда просто знать, какие показатели использовать С развитием глубокого обучения все больше и больше людей учатся обучать свой первый классификатор. Но как только вы закончите..

    Работа с цепями Маркова, часть 4 (Машинное обучение)
    Нелинейные цепи Маркова с агрегатором и их приложения (arXiv) Автор : Бар Лайт Аннотация: Изучаются свойства подкласса случайных процессов, называемых дискретными нелинейными цепями Маркова..

    Crazy Laravel Livewire упростил мне создание электронной коммерции (панель администратора и API) [Часть 3]
    Как вы сегодня, ребята? В этой части мы создадим CRUD для данных о продукте. Думаю, в этой части я не буду слишком много делиться теорией, но чаще буду делиться своим кодом. Потому что..


    Для любых предложений по сайту: [email protected]