Anyone know of a library that implements Coroutine...

# tornadofx

[darkmoon_uk]

Anyone know of a library that implements Coroutine Channel/Flow wrappings for JavaFX component events? Or is there space to grow a new one?

[Dominaezzz]

Not exactly an answer but I thought you might like to see it. https://kotlinlang.slack.com/archives/C1CFAFJSK/p1565187506478200

[Dominaezzz]

(I'm looking for something similar too)

[darkmoon_uk]

👍

[darkmoon_uk]

I've wrapped JavaFX Property at least, thanks to your help, next I need to define a Channel/Flow that immediately emits the current value of a Property, followed by any changes.

[darkmoon_uk]

Which is a hybrid cold/hot behaviour but something common in Rx.

[darkmoon_uk]

Useful when your code subscribes to a control part way through its lifecycle - which is again quite common once you are developing complex UI's with Rx, or wanting to emit default values that are defined in FXML i.e. set before the lifecycle.

[darkmoon_uk]

https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/channel-flow.html I think I need this in some form

[Dominaezzz]

ConflatedBroadcastChannel.

[darkmoon_uk]

I'll check it out... effectively I want to concatenate a cold flow of size 1, with a channel of subsequent updates

[Dominaezzz]

Yup, that's pretty much it.

[darkmoon_uk]

...just read. Delightful - thanks!!

[darkmoon_uk]

BTW I will share a lib once I get something test and worth sharing.

[darkmoon_uk]

Plenty of dog-fooding to go through first 😄

[darkmoon_uk]

Appeared too easy 😂

@ExperimentalCoroutinesApi
fun <T> Property<T>.values() : BroadcastChannel<T> {
    val values = ConflatedBroadcastChannel<T>(value)
    val listener = ChangeListener<T> { _,_,newValue ->
        values.offer(newValue)
    }
    addListener(listener)
    values.invokeOnClose { removeListener(listener) }
    return values
}

[Ruckus]

You might want to make specialized functions for the primitive number properties, as they are all Property<Number>.