Update Wonka to v6

Author: mobily

bsconfig.json

@@ -1,6 +1,6 @@
 {
   "name": "@mobily/stacks",
-  "version": "1.5.0",
+  "version": "2.2.2",
   "namespace": false,
   "bsc-flags": ["-bs-super-errors", "-bs-no-version-header"],
   "reason": {
@@ -32,8 +32,7 @@
   ],
   "bs-dependencies": [
     "@rescript/react",
-    "rescript-react-native",
-    "wonka"
+    "rescript-react-native"
   ],
   "ppx-flags": []
 }

src/Stacks_hooks.res

@@ -11,10 +11,9 @@ let useWindowDimensions = () => {
   React.useEffect0(() => {
     let subscription = {
       open Wonka
-      dimensionsSource
+      makeDimensionsSource()
       |> debounce((. _) => Platform.os == Platform.web ? 60 : 0)
-      |> onPush((. layout: Dimensions.handler) => setDimensions(_ => layout.window))
-      |> publish
+      |> subscribe((. layout: Dimensions.handler) => setDimensions(_ => layout.window))
     }
 
     Some(subscription.unsubscribe)

src/Stacks_utils.res

@@ -77,6 +77,20 @@ let splitEvery = (xs, size) => {
   }
 }
 
+let memo = fn => {
+  let lastResult = ref(None)
+
+  () => {
+    switch lastResult.contents {
+    | Some(result) => result
+    | None =>
+      let result = fn()
+      lastResult := Some(result)
+      result
+    }
+  }
+}
+
 let intersperse = (xs, delimiter) =>
   Belt.Array.reduceWithIndexU(xs, [], (. acc, value, index) => {
     switch index {
@@ -86,7 +100,7 @@ let intersperse = (xs, delimiter) =>
     acc
   })
 
-let dimensionsSource = {
+let makeDimensionsSource = memo(() => {
   open Wonka
 
   let source = make((. observer) => {
@@ -95,7 +109,7 @@ let dimensionsSource = {
   })
 
   share(source)
-}
+})
 
 let resolveCurrentBreakpoint = (~currentWidth: float, ~breakpoints: breakpoints) => {
   let defaultBreakpoint = Belt.Array.getUnsafe(defaultBreakpoints, 0)

src/Wonka.res

@@ -0,0 +1,16 @@
+type signalT<'a>
+type sinkT<'a> = (. signalT<'a>) => unit
+type sourceT<'a> = sinkT<'a> => unit
+type observerT<'a> = {
+  next: 'a => unit,
+  complete: unit => unit,
+}
+type teardownT = (. unit) => unit
+type operatorT<'a, 'b> = sourceT<'a> => sourceT<'b>
+type subscriptionT = {unsubscribe: unit => unit}
+type subscribeConsumerT<'a> = sourceT<'a> => subscriptionT
+
+@module("wonka") external make: ((. observerT<'a>) => teardownT) => sourceT<'a> = "make"
+@module("wonka") external share: sourceT<'a> => sourceT<'a> = "share"
+@module("wonka") external debounce: ((. 'a) => int) => operatorT<'a, 'a> = "debounce"
+@module("wonka") external subscribe: ((. 'a) => unit) => subscribeConsumerT<'a> = "subscribe"