Example: switch to the new res.* attributes.

Author: cristianoc

example-async/src/AA.res

@@ -9,22 +9,22 @@ let addTest1 = (t, x) => tests->Js.Array2.push((. ()) => t(. x))->ignore
 //
 // Basic tests
 
-let foo = @async (. x, y) => x + y
+let foo = @res.async (. x, y) => x + y
 
 let bar =
-  @async
+  @res.async
   (. ff) => {
-    let a = @await ff(. 3, 4)
-    let b = @await foo(. 5, 6)
+    let a = @res.await ff(. 3, 4)
+    let b = @res.await foo(. 5, 6)
     a + b
   }
 
-let baz = @async (. ()) => @await bar(. foo)
+let baz = @res.async (. ()) => @res.await bar(. foo)
 
 let testBaz: testable =
-  @async
+  @res.async
   (. ()) => {
-    let n = @await baz(.)
+    let n = @res.await baz(.)
     Js.log2("baz returned", n)
   }
 
@@ -36,16 +36,16 @@ testBaz->addTest
 
 exception E(int)
 
-let e1: testable = @async (. ()) => raise(E(1000))
-let e2: testable = @async (. ()) => Js.Exn.raiseError("Some JS error")
-let e3: testable = @async (. ()) => @await e1(.)
-let e4: testable = @async (. ()) => @await e2(.)
+let e1: testable = @res.async (. ()) => raise(E(1000))
+let e2: testable = @res.async (. ()) => Js.Exn.raiseError("Some JS error")
+let e3: testable = @res.async (. ()) => @res.await e1(.)
+let e4: testable = @res.async (. ()) => @res.await e2(.)
 let e5: testable = %raw(`function() { return Promise.reject(new Error('fail')) }`)
 
 let testTryCatch =
-  @async
+  @res.async
   (. fn) =>
-    try {@await fn(.)} catch {
+    try {@res.await fn(.)} catch {
     | E(n) => Js.log2("testTryCatch: E", n)
     | JsError(_) => Js.log("testTryCatch: JsError")
     }
@@ -60,10 +60,10 @@ testTryCatch->addTest1(e5)
 //
 // Check for nested promise
 
-let singlePromise = @async (. x) => x + 1
+let singlePromise = @res.async (. x) => x + 1
 
 let nestedPromise =
-  @async
+  @res.async
   (. x) => {
     let resolve = x => [Js.Promise.resolve(x)]
     let _result = singlePromise(. x + 1)->resolve
@@ -84,10 +84,10 @@ module Fetch = {
 let explainError: unknown => string = %raw(`(e)=>e.toString()`)
 
 let testFetch =
-  @async
+  @res.async
   (. url) => {
     open Fetch
-    switch {@await fetch(url)} {
+    switch {@res.await fetch(url)} {
     | response =>
       let status = response->status
       Js.log2("Fetch returned status:", status)
@@ -102,13 +102,13 @@ testFetch->addTest1("https://www.google.comsdkjdkghdsg")
 //
 // Callbacks
 let withCallback =
-  @async
+  @res.async
   (. ()) => {
-    @async (. x) => @await (x->Js.Promise.resolve) + 1
+    @res.async (. x) => @res.await (x->Js.Promise.resolve) + 1
   }
 
 let testWithCallback =
-  @async (. ()) => Js.log2("callback returned", @await (@await withCallback(.))(. 3))
+  @res.async (. ()) => Js.log2("callback returned", @res.await (@res.await withCallback(.))(. 3))
 
 testWithCallback->addTest
 
@@ -117,17 +117,17 @@ testWithCallback->addTest
 // Async list
 module AsyncList = {
   let map =
-    @async
+    @res.async
     (. l, f) => {
       let rec loop =
-        @async
+        @res.async
         (. l, acc) =>
           switch l {
           | list{} => acc
-          | list{p, ...rest} => @await loop(. rest, list{@await p, ...acc})
+          | list{p, ...rest} => @res.await loop(. rest, list{@res.await p, ...acc})
           }
 
-      @await
+      @res.await
       loop(. l->Belt.List.mapReverse(x => f(. x)), list{})
     }
 }
@@ -136,9 +136,9 @@ let fetchAndCount = {
   let counter = ref(0)
 
   let ff =
-    @async
+    @res.async
     (. url) => {
-      let response = @await Fetch.fetch(url)
+      let response = @res.await Fetch.fetch(url)
       counter := counter.contents + 1
       (counter.contents, response->Fetch.status)
     }
@@ -147,10 +147,10 @@ let fetchAndCount = {
 }
 
 let testFetchMany =
-  @async
+  @res.async
   (. ()) => {
     let fetchedItems =
-      @await
+      @res.await
       AsyncList.map(.
         list{
           "https://www.google.com",
@@ -170,9 +170,9 @@ testFetchMany->addTest
 // Fetch with Result type
 module FetchResult = {
   let fetch =
-    @async
+    @res.async
     (. url) => {
-      switch {@await Fetch.fetch(url)} {
+      switch {@res.await Fetch.fetch(url)} {
       | response => Ok(response)
       | exception JsError(e) => Error(e)
       }
@@ -182,16 +182,16 @@ module FetchResult = {
 let nextFetch = (. _response) => Some("https://github.com/")
 
 let testFetchWithResult =
-  @async
+  @res.async
   (. ()) => {
-    switch @await
+    switch @res.await
     FetchResult.fetch(. "https://www.google.com") {
     | Ok(response1) =>
       Js.log2("FetchResult response1", response1->Fetch.status)
       switch nextFetch(. response1) {
       | None => ()
       | Some(url) =>
-        switch @await
+        switch @res.await
         FetchResult.fetch(. url) {
         | Ok(response2) => Js.log2("FetchResult response2", response2->Fetch.status)
         | Error(_) => ()
@@ -216,13 +216,13 @@ testFetchWithResult->addTest
 // Run tests
 
 let rec runAllTests =
-  @async
+  @res.async
   (. n) => {
     if n >= 0 && n < Array.length(tests) {
-      @await
+      @res.await
       (@doesNotRaise tests[n])(.)
 
-      @await
+      @res.await
       runAllTests(. n + 1)
     }
   }
@@ -233,23 +233,23 @@ runAllTests(. 0)->ignore
 //
 // Curried functions
 
-let bb = @async x => @await x
+let bb = @res.async x => @res.await x
 
-let cc = @async (x, ~y=x, z) => @await x + @await y + @await z
+let cc = @res.async (x, ~y=x, z) => (@res.await x) + (@res.await y) + (@res.await z)
 
-let dd = @async x => {y => @await x + @await y}
+let dd = @res.async x => {y => (@res.await x) + (@res.await y)}
 
-let ee = @async (. x) => {y => @await x + @await y}
+let ee = @res.async (. x) => {y => (@res.await x) + (@res.await y)}
 
 //
 //
 // Errors
 
 // let aa =
-//   @async
+//   @res.async
 //   (. x) => {
-//     let cb = (. _) => @await x // Error: Await on expression not in an async context
+//     let cb = (. _) => @res.await x // Error: Await on expression not in an async context
 //     cb
 //   }
 
-// let _ = @async (_, . x) => @await x // Error: Await on expression not in an async context
+// let _ = @res.async (_, . x) => @res.await x // Error: Await on expression not in an async context