Skip to content

Commit

Permalink
add Resolved to Async and move rejected to Rejected
Browse files Browse the repository at this point in the history
  • Loading branch information
Ian Hofmann-Hicks committed Feb 18, 2017
1 parent d698ec7 commit 909f9f4
Show file tree
Hide file tree
Showing 5 changed files with 38 additions and 16 deletions.
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ All `Crocks` are Constructor functions of the given type, with `Writer` being an
| Crock | Constructor | Instance |
|---|:---|:---|
| `Arrow` | `empty` | `both`, `concat`, `contramap`, `empty`, `first`, `map`, `promap`, `runWith`, `second`, `value` |
| `Async` | `all`, `fromNode`, `fromPromise`, `of`, `rejected` | `ap`, `bimap`, `chain`, `coalesce`, `fork`, `map`, `of`, `swap`, `toPromise` |
| `Async` | , `Rejected`, `Resolved`, `all`, `fromNode`, `fromPromise`, `of` | `ap`, `bimap`, `chain`, `coalesce`, `fork`, `map`, `of`, `swap`, `toPromise` |
| `Const` | -- | `ap`, `chain`, `concat`, `equals`, `map`, `value` |
| `Either` | `Left`, `Right`, `of`| `ap`, `bimap`, `chain`, `coalesce`, `either`, `equals`, `map`, `of`, `sequence`, `swap`, `traverse` |
| `Identity` | `of` | `ap`, `chain`, `equals`, `map`, `of`, `sequence`, `traverse`, `value` |
Expand Down Expand Up @@ -412,7 +412,7 @@ const anotherInc =

// resolveValue : a -> Async _ a
const resolveValue =
Async.of
Async.Resolved

resolveValue(3) // Resolved 3
.chain(asyncInc) // Resolved 4
Expand Down
8 changes: 6 additions & 2 deletions crocks/Async.js
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ const _type =
const _of =
x => Async((_, resolve) => resolve(x))

const _rejected =
const Rejected =
x => Async((reject, _) => reject(x))

function all(asyncs) {
Expand Down Expand Up @@ -221,9 +221,13 @@ function Async(fn) {

Async.type = _type
Async.of = _of
Async.rejected = _rejected

Async.Rejected = Rejected
Async.Resolved = _of

Async.fromPromise = fromPromise
Async.fromNode = fromNode

Async.all = all

module.exports = Async
36 changes: 27 additions & 9 deletions crocks/Async.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,10 @@ test('Async', t => {

t.ok(isFunction(Async.of), 'provides an of function')
t.ok(isFunction(Async.type), 'provides a type function')
t.ok(isFunction(Async.rejected), 'provides a rejected function')

t.ok(isFunction(Async.Resolved), 'provides a Resolved function')
t.ok(isFunction(Async.Rejected), 'provides a Rejected function')

t.ok(isFunction(Async.fromPromise), 'provides a fromPromise function')

t.throws(Async, TypeError, 'throws with no parameters')
Expand All @@ -42,9 +45,9 @@ test('Async', t => {
t.end()
})

test('Async rejected', t => {
test('Async Rejected', t => {
const x = 'sorry'
const m = Async.rejected(x)
const m = Async.Rejected(x)

const rej = sinon.spy()
const res = sinon.spy()
Expand All @@ -57,6 +60,21 @@ test('Async rejected', t => {
t.end()
})

test('Async Resolved', t => {
const x = 'sorry'
const m = Async.Resolved(x)

const rej = sinon.spy()
const res = sinon.spy()

m.fork(rej, res)

t.ok(res.calledWith(x), 'calls the resolved function with resolved value')
t.notOk(rej.called, 'does not call the rejected function')

t.end()
})

test('Async fromPromise', t => {
const resProm = x => new Promise((res, _) => res(x))

Expand Down Expand Up @@ -186,8 +204,8 @@ test('Async all resolution', t => {
const res = y => x => t.same(x, y, 'resolves with array of values when all resolve')
const empty = y => x => t.same(x, y, 'resolves with an empty array when passed an empty array')

Async.all([ Async.of(val), Async.of(val) ]).fork(rej(bad), res([ val, val ]))
Async.all([ Async.rejected(bad), Async.of(val) ]).fork(rej(bad), res([ val, val ]))
Async.all([ Async.Resolved(val), Async.Resolved(val) ]).fork(rej(bad), res([ val, val ]))
Async.all([ Async.Rejected(bad), Async.Resolved(val) ]).fork(rej(bad), res([ val, val ]))
Async.all([]).fork(rej(bad), empty([]))

t.end()
Expand Down Expand Up @@ -256,8 +274,8 @@ test('Async toPromise', t => {
const rej = y => x => t.equal(x, y, 'rejects a rejected Async')
const res = y => x => t.equal(x, y, 'resolves a resolved Async')

Async.rejected(val).toPromise().then(res(val)).catch(rej(val))
Async.of(val).toPromise().then(res(val)).catch(rej(val))
Async.Rejected(val).toPromise().then(res(val)).catch(rej(val))
Async.Resolved(val).toPromise().then(res(val)).catch(rej(val))

t.plan(2)
})
Expand Down Expand Up @@ -454,8 +472,8 @@ test('Async bimap functionality', t => {
test('Async bimap properties (Bifunctor)', t => {
const bimap = (f, g) => m => m.bimap(f, g)

const rej = Async.rejected(10)
const res = Async.of(10)
const rej = Async.Rejected(20)
const res = Async.Resolved(10)

const rejId = sinon.spy()
const resId = sinon.spy()
Expand Down
2 changes: 1 addition & 1 deletion transforms/eitherToAsync.js
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ const Either = require('../crocks/Either')
const Async = require('../crocks/Async')

const applyTransform = either =>
either.either(Async.rejected, Async.of)
either.either(Async.Rejected, Async.Resolved)

// eitherToAsync : Either e a -> Async e a
// eitherToAsync : (a -> Either e b) -> a -> Async e b
Expand Down
4 changes: 2 additions & 2 deletions transforms/maybeToAsync.js
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,8 @@ const Async = require('../crocks/Async')

const applyTransform = (left, maybe) =>
maybe.either(
constant(Async.rejected(left)),
Async.of
constant(Async.Rejected(left)),
Async.Resolved
)

// maybeToAsync : e -> Maybe a -> Async e a
Expand Down

0 comments on commit 909f9f4

Please sign in to comment.