Support onReceive

Package.swift

@@ -9,7 +9,7 @@ let package = Package(
     ],
     dependencies: [ 
         .package(url: "https://source.skip.tools/skip.git", from: "0.8.32"),
-        .package(url: "https://source.skip.tools/skip-model.git", from: "0.6.0"),
+        .package(url: "https://source.skip.tools/skip-model.git", from: "0.6.1"),
     ],
     targets: [
         .target(name: "SkipUI", dependencies: [.product(name: "SkipModel", package: "skip-model")], plugins: [.plugin(name: "skipstone", package: "skip")]),

README.md

@@ -1150,6 +1150,10 @@ Support levels:
       <td>✅</td>
       <td><code>.onMove</code></td>
     </tr>
+    <tr>
+      <td>✅</td>
+      <td><code>.onReceive</code></td>
+    </tr>
     <tr>
       <td>✅</td>
       <td><code>.onSubmit</code></td>

Sources/SkipUI/SkipUI/View/Observable.swift

@@ -4,10 +4,34 @@
 // under the terms of the GNU Lesser General Public License 3.0
 // as published by the Free Software Foundation https://fsf.org
 
+import Combine
+#if SKIP
+import androidx.compose.runtime.DisposableEffect
+import androidx.compose.runtime.remember
+import androidx.compose.runtime.rememberUpdatedState
+#endif
+
 extension View {
-    @available(*, unavailable)
-    public func onReceive<P>(_ publisher: P, perform action: @escaping (Any /* P.Output */) -> Void) -> some View /* where P : Publisher, P.Failure == Never */ {
+    // SKIP DECLARE: fun <P, Output> onReceive(publisher: P, perform: (Output) -> Unit): View where P: Publisher<Output, *>
+    public func onReceive<P>(_ publisher: P, perform action: @escaping (P.Output) -> Void) -> some View where P : Publisher {
+        #if SKIP
+        return ComposeModifierView(targetView: self) { _ in
+            let latestAction = rememberUpdatedState(action)
+            let subscription = remember {
+                publisher.sink { output in
+                    latestAction.value(output)
+                }
+            }
+            DisposableEffect(subscription) {
+                onDispose {
+                    subscription.cancel()
+                }
+            }
+            return ComposeResult.ok
+        }
+        #else
         return self
+        #endif
     }
 }