Updated examples and tests to be in more "rescript" style.

Use -> pipes instead of |>
Switch from Js.Promise to @ryyppy/rescript-promise

Author: TheSpyder

bsconfig.json

@@ -19,5 +19,8 @@
   "warnings": {
     "number": "+A-105",
     "error": "+A"
-  }
+  },
+  "bs-dev-dependencies": [
+    "@ryyppy/rescript-promise"
+  ]
 }

examples/fetch_examples.res

@@ -1,35 +1,33 @@
-open Webapi;
+open Webapi
+open Promise
+
 let _ = {
-  open Js.Promise
   Fetch.fetch("/api/hellos/1")
-  |> then_(Fetch.Response.text)
-  |> then_(text => print_endline(text) |> resolve)
+  ->then(Fetch.Response.text)
+  ->then(text => print_endline(text)->resolve)
 }
 
 let _ = {
-  open Js.Promise
   Fetch.fetchWithInit("/api/hello", Fetch.RequestInit.make(~method_=Post, ()))
-  |> then_(Fetch.Response.text)
-  |> then_(text => print_endline(text) |> resolve)
+  ->then(Fetch.Response.text)
+  ->then(text => print_endline(text)->resolve)
 }
 
 let _ = {
-  open Js.Promise
   Fetch.fetch("/api/fruit")
   /* assume server returns `["apple", "banana", "pear", ...]` */
-  |> then_(Fetch.Response.json)
-  |> then_(json => Js.Json.decodeArray(json) |> resolve)
-  |> then_(opt => Belt.Option.getExn(opt) |> resolve)
-  |> then_(items =>
-    items |> Js.Array.map(item => item |> Js.Json.decodeString |> Belt.Option.getExn) |> resolve
+  ->then(Fetch.Response.json)
+  ->then(json => Js.Json.decodeArray(json)->resolve)
+  ->then(opt => Belt.Option.getExn(opt)->resolve)
+  ->then(items =>
+    items->Js.Array2.map(item => item->Js.Json.decodeString->Belt.Option.getExn)->resolve
   )
 }
 
 /* makes a post request with the following json payload { hello: "world" } */
 let _ = {
   let payload = Js.Dict.empty()
   Js.Dict.set(payload, "hello", Js.Json.string("world"))
-  open Js.Promise
   Fetch.fetchWithInit(
     "/api/hello",
     Fetch.RequestInit.make(
@@ -38,7 +36,7 @@ let _ = {
       ~headers=Fetch.HeadersInit.make({"Content-Type": "application/json"}),
       (),
     ),
-  ) |> then_(Fetch.Response.json)
+  )->then(Fetch.Response.json)
 }
 
 let _ = {
@@ -47,10 +45,9 @@ let _ = {
     formData,
     "image0",
     {"type": "image/jpg", "uri": "path/to/it", "name": "image0.jpg"},
-    ()
+    (),
   )
 
-  open Js.Promise
   Fetch.fetchWithInit(
     "/api/upload",
     Fetch.RequestInit.make(
@@ -59,16 +56,13 @@ let _ = {
       ~headers=Fetch.HeadersInit.make({"Accept": "*"}),
       (),
     ),
-  ) |> then_(Fetch.Response.json)
+  )->then(Fetch.Response.json)
 }
 
 let _ = {
   let controller = Fetch.AbortController.make()
 
-  let _ = Fetch.fetchWithInit(
-    "/api/fruit",
-    Fetch.RequestInit.make(~signal=controller.signal, ())
-  )
-  
+  let _ = Fetch.fetchWithInit("/api/fruit", Fetch.RequestInit.make(~signal=controller.signal, ()))
+
   controller->Fetch.AbortController.abort
-}
+}

package.json

@@ -29,6 +29,7 @@
   "author": "Tiny Technologies Inc",
   "license": "MIT",
   "devDependencies": {
+    "@ryyppy/rescript-promise": "^2.1.0",
     "rescript": "^9.1.4"
   }
 }

tests/Webapi/Webapi__Blob__test.res

@@ -1,17 +1,18 @@
 open Webapi.Blob
 
 let test_arrayBuffer = blob =>
-  blob->arrayBuffer
-    |> Js.Promise.then_(buffer =>
-      buffer->Js.Typed_array.ArrayBuffer.byteLength->Js.log->Js.Promise.resolve
-    )
+  blob
+  ->arrayBuffer
+  ->Promise.then(buffer =>
+    buffer->Js.Typed_array.ArrayBuffer.byteLength->Js.log->Promise.resolve
+  )
 
 let test_size = blob => blob->size->Js.log
 
 let test_slice = blob => test_size(blob->slice(~start=0, ()))
 
 let test_stream = blob => blob->stream
 
-let test_text = blob => blob->text |> Js.Promise.then_(string => string->Js.log->Js.Promise.resolve)
+let test_text = blob => blob->text->Promise.then(string => string->Js.log->Promise.resolve)
 
 let test_type = blob => blob->type_->Js.log

tests/Webapi/Webapi__ReadableStream__test.res

@@ -6,18 +6,19 @@ module DefaultReader__test = {
   let test_closed = reader => closed(reader)
 
   let test_cancel = reader =>
-    reader->cancel |> Js.Promise.then_(() => "cancelled"->Js.log->Js.Promise.resolve)
+    reader->cancel->Promise.then(() => "cancelled"->Js.log->Promise.resolve)
 
   let test_cancelWith = reader =>
-    reader->cancelWith("reason") |> Js.Promise.then_(reason => reason->Js.log->Js.Promise.resolve)
+    reader->cancelWith("reason")->Promise.then(reason => reason->Js.log->Promise.resolve)
 
   let test_releaseLock = reader => releaseLock(reader)
 
   let test_read = reader =>
-    reader->read
-      |> Js.Promise.then_(next =>
-        next->Webapi__Iterator.value->Belt.Option.forEach(_, Js.log)->Js.Promise.resolve
-      )
+    reader
+    ->read
+    ->Promise.then(next =>
+      next->Webapi__Iterator.value->Belt.Option.forEach(_, Js.log)->Promise.resolve
+    )
 }
 
 let test_locked = stream => locked(stream)

yarn.lock

@@ -2,6 +2,11 @@
 # yarn lockfile v1
 
 
+"@ryyppy/rescript-promise@^2.1.0":
+  version "2.1.0"
+  resolved "https://registry.yarnpkg.com/@ryyppy/rescript-promise/-/rescript-promise-2.1.0.tgz#a33861274c41360cfbe872cf489f3dcb8dd526e6"
+  integrity sha512-+dW6msBrj2Lr2hbEMX+HoWCvN89qVjl94RwbYWJgHQuj8jm/izdPC0YzxgpGoEFdeAEW2sOozoLcYHxT6o5WXQ==
+
 rescript@^9.1.4:
   version "9.1.4"
   resolved "https://registry.yarnpkg.com/rescript/-/rescript-9.1.4.tgz#1eb126f98d6c16942c0bf0df67c050198e580515"