Added promise() method

README.md

@@ -181,6 +181,7 @@ Output:
 - [`ap`](#ap)
 - [`chain`](#chain)
 - [`bimap`](#bimap)
+- [`future`](#future)
 
 ### Consuming / Collapsing Methods
 - [`fork`](#fork)
@@ -310,6 +311,13 @@ Call the function wrapped as future value in the supplied IodioInstance passing
 Returns:  **IodioInstance**
 - - -
 
+### <a id="ap"></a> `future()`
+
+Transform Iodio to a Fluture Future wich wrapped value equals query result plus computation. No query is executed calling this method, query and computation will be done at time of forking returned future.
+
+Returns:  **FutureInstance**
+- - -
+
 ## Consuming / Collapsing Methods
 
 ### <a id="fork"></a> `fork(left)(right)`

index.js

@@ -80,6 +80,7 @@ const { Reader } = Monet
  *      fork: (left: any) => (right: any) => F.Cancel;
  *      collapse: () => FutureInstanceT<T>;
  *      promise: () => Promise<any>;
+ *      future: () => FutureInstanceT<T>;
  *      toString: () => string;
  *      first: () => Promise<any>;
  *      'fantasy-land/map': (pred: ResultPredicate<T, T>)  => IodioInstance<T>;
@@ -170,6 +171,10 @@ const Iodio = (pPred, qbR, fR) => {
 
     const first = () => promise().then(r => r && (Array.isArray(r) ? r[0] : r))
 
+    const future = () => F.Future(
+        (reject, resolve) => collapse().pipe(F.fork(reject)(resolve))
+    )
+
     return {
         pMap,
         qMap,
@@ -183,6 +188,7 @@ const Iodio = (pPred, qbR, fR) => {
         toString,
         first,
         collapse,
+        future,
         // Fantay Land Interface
         'fantasy-land/map': map,
         'fantasy-land/ap': ap,

package.json

@@ -1,6 +1,6 @@
 {
     "name": "iodio",
-    "version": "0.1.1",
+    "version": "0.1.2",
     "type": "module",
     "description": "Monadic query builder (Knex wrapper: Fluture powered)",
     "main": "index.js",

tests/core.test.js

@@ -242,7 +242,7 @@ test('Bifunctor: bimap', async t => {
 })
 
 test('Bifunctor: identity', async t => {
-    const { u, g1, f1 } = t.context
+    const { u } = t.context
     t.deepEqual(await u.bimap(I, I).first(), await u.first())
 })
 
@@ -268,3 +268,25 @@ test('Bifunctor: composition', async t => {
             .first()
     )
 })
+
+test('to future', async t => {
+    const { db } = t.context
+    let lazyGuard = true
+    const query = Iodio.lift(db, ['Track'])
+        .qMap(qb => {
+            lazyGuard = false
+            return qb.where({ Composer: 'Nirvana' })
+        })
+        .qMap(qb => qb.limit(2))
+        .map(rows => {
+            lazyGuard = false
+            return rows.map(track => track.Name)
+        })
+
+    t.is(lazyGuard, true)
+    const futureValue = await query.future()
+    t.is(lazyGuard, true)
+    const value = await F.promise(futureValue)
+    t.is(lazyGuard, false)
+    t.deepEqual(value, ['Aneurysm', 'Smells Like Teen Spirit'])
+})