Allow to bindOut a flow

README.md

@@ -76,13 +76,16 @@ val binding = viewLifecycleOwner.bindIn(flow) {
     button.setOnCheckedChangeListener { _, isChecked ->
       observer(isChecked)
     }
+    fun() {
+        button.setOnCheckedChangeListener(null)
+    }
   },
   pipe = {
     flow.value = it
   },
 )
 ```
-for some of the views there's already a `bindOut` function
+for some of the views there's already a `bindOut` function.
 ```kotlin
 val flow = MutableStateFlow<Boolean>(false)
 val binding = viewLifecycleOwner.bindIn(flow) {
@@ -92,6 +95,16 @@ val binding = viewLifecycleOwner.bindIn(flow) {
 }
 ```
 
+You may also want to pass `Flow` to the `bindOut` function.
+```kotlin
+val flow = MutableStateFlow<Boolean>(false)
+val binding = viewLifecycleOwner.bindIn(flow) {
+  button.isChecked = it
+}.bindOut(button.checked()) {
+  flow.value = it
+}
+```
+
 Report a bug or request a feature
 ----------------
 Before creating a new issue please make sure that same or similar issue is not already created by checking [open issues][2] and [closed issues][3] *(please note that there might be multiple pages)*. If your issue is already there, don't create a new one, but leave a comment under already existing one.

library/src/main/java/com/artemchep/bindin/BindIn.kt

@@ -63,6 +63,8 @@ private inline fun <T> LifecycleOwner._bindIn(
         },
     )
     return InBinding(
+        lifecycleOwner = this,
+        minimumLifecycleState = minimumLifecycleState,
         data = inBindingData,
         unbind = registration,
     )

library/src/main/java/com/artemchep/bindin/BindInLiveData.kt

@@ -1,6 +1,7 @@
 package com.artemchep.bindin
 
 import androidx.annotation.UiThread
+import androidx.lifecycle.Lifecycle
 import androidx.lifecycle.LifecycleOwner
 import androidx.lifecycle.LiveData
 import androidx.lifecycle.Observer
@@ -17,6 +18,8 @@ fun <T> LifecycleOwner.bindIn(
     }
 
     val inBinding = InBinding(
+        lifecycleOwner = this,
+        minimumLifecycleState = Lifecycle.State.STARTED,
         data = inBindingData,
     ) {
         liveData.removeObserver(observer)

library/src/main/java/com/artemchep/bindin/BindOut.kt

@@ -1,16 +1,56 @@
 package com.artemchep.bindin
 
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.collect
+
 fun <T> InBinding<T>.bindOut(
-    observe: (callback: (T) -> Unit) -> Unit,
+    observe: (callback: (T) -> Unit) -> () -> Unit,
     /** A pipe to pass data to... */
     pipe: (T) -> Unit,
-) {
-    observe { value ->
+): InBinding<T> {
+    val unbindObserve = observe { value ->
         if (data.eq(value)) {
             return@observe
         }
 
         data.outValue = value
         pipe(value)
     }
+    return copy(
+        unbind = {
+            unbind()
+            unbindObserve()
+        }
+    )
+}
+
+fun <T> InBinding<T>.bindOut(
+    flow: Flow<T>,
+    /** A pipe to pass data to... */
+    pipe: (T) -> Unit,
+): InBinding<T> {
+    val unbindBlock = lifecycleOwner.bindBlock(minimumLifecycleState = minimumLifecycleState) {
+        flow.collect {
+            _pipe(it, pipe)
+        }
+    }
+    return copy(
+        unbind = {
+            unbind()
+            unbindBlock()
+        }
+    )
+}
+
+private fun <T> InBinding<T>._pipe(
+    value: T,
+    /** A pipe to pass data to... */
+    pipe: (T) -> Unit,
+) {
+    if (data.eq(value)) {
+        return
+    }
+
+    data.outValue = value
+    pipe(value)
 }

library/src/main/java/com/artemchep/bindin/Model.kt

@@ -1,6 +1,11 @@
 package com.artemchep.bindin
 
-class InBinding<T>(
+import androidx.lifecycle.Lifecycle
+import androidx.lifecycle.LifecycleOwner
+
+data class InBinding<T>(
+    val lifecycleOwner: LifecycleOwner,
+    val minimumLifecycleState: Lifecycle.State,
     val data: InBindingData<T>,
     val unbind: () -> Unit,
 )

library/src/main/java/com/artemchep/bindin/common/BindCompoundButton.kt

@@ -21,6 +21,10 @@ fun InBinding<Boolean>.bindOut(
         view.setOnCheckedChangeListener { _, isChecked ->
             observer(isChecked)
         }
+
+        fun() {
+            view.setOnCheckedChangeListener(null)
+        }
     },
     pipe = pipe
 )

library/src/main/java/com/artemchep/bindin/common/BindEditText.kt

@@ -22,9 +22,13 @@ fun InBinding<String>.bindOut(
     pipe: (String) -> Unit,
 ) = bindOut(
     observe = { observer ->
-        editText.addTextChangedListener {
+        val listener = editText.addTextChangedListener {
             observer(it?.toString().orEmpty())
         }
+
+        fun() {
+            editText.removeTextChangedListener(listener)
+        }
     },
     pipe = pipe
 )