diff options
| author | Robert Jaros <rjaros@finn.pl> | 2019-10-13 20:04:35 +0200 |
|---|---|---|
| committer | Robert Jaros <rjaros@finn.pl> | 2019-10-13 20:04:35 +0200 |
| commit | fb41b9fbdb8e298d5cb69168dd53a6945a6348b1 (patch) | |
| tree | 2713808a67e6360c28244dddaa6de202a3dfc9d3 /kvision-modules | |
| parent | 780c340a481676e27398dccf4503e8f0b9c63060 (diff) | |
| download | kvision-fb41b9fbdb8e298d5cb69168dd53a6945a6348b1.tar.gz kvision-fb41b9fbdb8e298d5cb69168dd53a6945a6348b1.tar.bz2 kvision-fb41b9fbdb8e298d5cb69168dd53a6945a6348b1.zip | |
Allow to unsubscribe from the ObservableState.
Diffstat (limited to 'kvision-modules')
2 files changed, 6 insertions, 6 deletions
diff --git a/kvision-modules/kvision-redux-kotlin/src/main/kotlin/pl/treksoft/kvision/redux/ReduxStore.kt b/kvision-modules/kvision-redux-kotlin/src/main/kotlin/pl/treksoft/kvision/redux/ReduxStore.kt index a37f1ac9..c4889567 100644 --- a/kvision-modules/kvision-redux-kotlin/src/main/kotlin/pl/treksoft/kvision/redux/ReduxStore.kt +++ b/kvision-modules/kvision-redux-kotlin/src/main/kotlin/pl/treksoft/kvision/redux/ReduxStore.kt @@ -96,10 +96,10 @@ class ReduxStore<S : Any, A : RAction>( store.dispatch(thunk) } - override fun subscribe(observer: (S) -> Unit) { - store.subscribe { + override fun subscribe(observer: (S) -> Unit): () -> Unit { + observer(getState()) + return store.subscribe { observer(getState()) } - observer(getState()) } } diff --git a/kvision-modules/kvision-redux/src/main/kotlin/pl/treksoft/kvision/redux/ReduxStore.kt b/kvision-modules/kvision-redux/src/main/kotlin/pl/treksoft/kvision/redux/ReduxStore.kt index 93c4f6a9..2fd0b744 100644 --- a/kvision-modules/kvision-redux/src/main/kotlin/pl/treksoft/kvision/redux/ReduxStore.kt +++ b/kvision-modules/kvision-redux/src/main/kotlin/pl/treksoft/kvision/redux/ReduxStore.kt @@ -112,10 +112,10 @@ class ReduxStore<S : Any, A : RAction>( }) } - override fun subscribe(observer: (S) -> Unit) { - store.subscribe { + override fun subscribe(observer: (S) -> Unit): () -> Unit { + observer(getState()) + return store.subscribe { observer(getState()) } - observer(getState()) } } |