can i poll all items of a buffered channel as a list my inte kotlinlang #coroutines

Channels

100daysofkotlin

100daysofkotlin-2021

algolialibraries

android-architecture

android-databinding

androidgithubprojects

androidx-xprocessing

arrow-contributors

beepiz-libraries

cincinnati-user-group

codemash-precompiler

codingconventions

competitive-programming

competitivecoding

compose-android

compose-desktop

compose-ui-showcase

connect-audit-events

cscenter-course-2016

domain-driven-design

effective-kotlin

effectivekotlin

embedded-kotlin

event21-community-content

fb-internal-demo

fluid-libraries

framework-elide

getting-started

github-workflows-kt

graviton-browser

image-processing

intellij-plugins

intellij-tricks

introduce-yourself

java-to-kotlin-refactoring

jhipster-kotlin

jvm-ir-backend-feedback

k2-early-adopters

kotest-contributors

kotlin-by-example

kotlin-data-storage

kotlin-foundation

kotlin-in-action

kotlin-multiplatform-contest

kotlin-pakistan

kotlinforbeginners

kotlingforbeginners

kotlinprogrammers

kotlintest-devs

kotlinultimatechallenge

kotlinx-datetime

lambdaworld_cadiz

language-evolution

language-proposals

leedskotlinusergroup

library-development

machinelearningbawas

myndocs-oauth2-server

navigation-architecture-component

ohio-kotlin-users

pattern-matching

pocketgitclient

practical-functional-programming

prozis-android-backup

python-contributors

realworldkotlin

refactoring-to-kotlin

refreshversions

russian-kotlinasfirst

skia-wasm-interop-temp

sofl-user-group

spring-security

squarelibraries

stayhungrystayfoolish

strife-discord-lib

swagger-gradle-codegen

swiss-user-group

tricity-kotlin-user-group

Title

n

Nikky

12/03/2020, 1:28 PM

can i poll all items of a buffered channel as a list ? my intent is to ingest events into a buffered channel and at a set rate bulk insert all that are currently in the buffered channel is that the correct way to handle this or is there cleaner constructs provided by coroutines that i am missing ? one of the requirements is that inserting events should cause backpressure

my code currently looks like so:

@OptIn(ExperimentalStdlibApi::class)
val wrappedEvents = buildList {
    // collect all events in ingestChannel until empty
    do {
        val ingested = ingestChannel.poll()
        if (ingested != null) {
            add(ingested)
        }
    } while (ingested != null)
}

// processing events afterwards

d

Dominaezzz

12/03/2020, 3:32 PM

I think you have to do this yourself ATM.

n

Nikky

12/03/2020, 3:33 PM

i am mostly just asking to have some more experienced people have a glance and tell me if i am doing something truly stupid, if there is no facepalm reactions then all is good

d

Dominaezzz

12/03/2020, 3:38 PM

Perhaps a while true and a break. Or maybe generateSequence and toList.

As long as your channel isn't coming from a flow, I don't think you'll get any face palms lol.

3 Views

#coroutines Join Slack