diff options
| -rw-r--r-- | build.gradle | 1 | ||||
| -rw-r--r-- | kvision-modules/kvision-event-flow/build.gradle | 5 | ||||
| -rw-r--r-- | kvision-modules/kvision-event-flow/package.json.d/project.info | 3 | ||||
| -rw-r--r-- | kvision-modules/kvision-event-flow/src/main/kotlin/pl/treksoft/kvision/event/EventFlow.kt | 81 | ||||
| -rw-r--r-- | settings.gradle | 1 |
5 files changed, 91 insertions, 0 deletions
diff --git a/build.gradle b/build.gradle index 000218cc..dda5105b 100644 --- a/build.gradle +++ b/build.gradle @@ -178,6 +178,7 @@ dokka { 'kvision-modules/kvision-tabulator/src/main/kotlin', 'kvision-modules/kvision-pace/src/main/kotlin', 'kvision-modules/kvision-bootstrap-typeahead/src/main/kotlin', + 'kvision-modules/kvision-event-flow/src/main/kotlin', 'kvision-modules/kvision-remote/src/main/kotlin', 'kvision-modules/kvision-bootstrap-select-remote/src/main/kotlin', 'kvision-modules/kvision-tabulator-remote/src/main/kotlin', diff --git a/kvision-modules/kvision-event-flow/build.gradle b/kvision-modules/kvision-event-flow/build.gradle new file mode 100644 index 00000000..4aaef76d --- /dev/null +++ b/kvision-modules/kvision-event-flow/build.gradle @@ -0,0 +1,5 @@ +apply from: "../shared.gradle" + +dependencies { + compile "org.jetbrains.kotlinx:kotlinx-coroutines-core-js:$coroutinesVersion" +} diff --git a/kvision-modules/kvision-event-flow/package.json.d/project.info b/kvision-modules/kvision-event-flow/package.json.d/project.info new file mode 100644 index 00000000..f9d34fd1 --- /dev/null +++ b/kvision-modules/kvision-event-flow/package.json.d/project.info @@ -0,0 +1,3 @@ +{ + "description": "KVision event flow module" +} diff --git a/kvision-modules/kvision-event-flow/src/main/kotlin/pl/treksoft/kvision/event/EventFlow.kt b/kvision-modules/kvision-event-flow/src/main/kotlin/pl/treksoft/kvision/event/EventFlow.kt new file mode 100644 index 00000000..3a93d2a5 --- /dev/null +++ b/kvision-modules/kvision-event-flow/src/main/kotlin/pl/treksoft/kvision/event/EventFlow.kt @@ -0,0 +1,81 @@ +/* + * Copyright (c) 2017-present Robert Jaros + * + * Permission is hereby granted, free of charge, to any person obtaining a copy + * of this software and associated documentation files (the "Software"), to deal + * in the Software without restriction, including without limitation the rights + * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell + * copies of the Software, and to permit persons to whom the Software is + * furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be included in all + * copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR + * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, + * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE + * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER + * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, + * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE + * SOFTWARE. + */ +package pl.treksoft.kvision.event + +import kotlinx.coroutines.ExperimentalCoroutinesApi +import kotlinx.coroutines.channels.awaitClose +import kotlinx.coroutines.flow.Flow +import kotlinx.coroutines.flow.callbackFlow +import org.w3c.dom.events.Event +import pl.treksoft.kvision.core.Widget +import pl.treksoft.kvision.core.onEvent + +@UseExperimental(ExperimentalCoroutinesApi::class) +inline fun <reified T : Widget> T.eventFlow(event: String): Flow<Pair<T, Event>> = callbackFlow { + val id = onEvent { + this.asDynamic()[event] = { e: Event -> + offer(self to e) + } + } + awaitClose { + removeEventListener(id) + } +} + +@UseExperimental(ExperimentalCoroutinesApi::class) +inline val <reified T : Widget> T.clickFlow: Flow<T> + get() = callbackFlow { + val id = onEvent { + click = { + offer(self) + } + } + awaitClose { + removeEventListener(id) + } + } + +@UseExperimental(ExperimentalCoroutinesApi::class) +inline val <reified T : Widget> T.inputFlow: Flow<T> + get() = callbackFlow { + val id = onEvent { + input = { + offer(self) + } + } + awaitClose { + removeEventListener(id) + } + } + +@UseExperimental(ExperimentalCoroutinesApi::class) +inline val <reified T : Widget> T.changeFlow: Flow<T> + get() = callbackFlow { + val id = onEvent { + change = { + offer(self) + } + } + awaitClose { + removeEventListener(id) + } + } diff --git a/settings.gradle b/settings.gradle index 535526c1..4f16117f 100644 --- a/settings.gradle +++ b/settings.gradle @@ -26,6 +26,7 @@ include 'kvision-modules:kvision-base', 'kvision-modules:kvision-maps', 'kvision-modules:kvision-moment', 'kvision-modules:kvision-pace', + 'kvision-modules:kvision-event-flow', 'kvision-modules:kvision-remote', 'kvision-modules:kvision-tabulator-remote', 'kvision-modules:kvision-server-javalin', |