Skip to content

Commit

Permalink
[breaking] junk-bucket/future now exports Future as a component of th…
Browse files Browse the repository at this point in the history
…e module
  • Loading branch information
meschbach committed Feb 12, 2020
1 parent c4248e9 commit 3915201
Show file tree
Hide file tree
Showing 9 changed files with 23 additions and 18 deletions.
10 changes: 6 additions & 4 deletions future.js
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,9 @@ async function parallel( promises ){
return out.good;
}

module.exports = Future
module.exports.delay = delay;
module.exports.promiseEvent = promiseEvent;
module.exports.parallel = parallel;
module.exports = {
Future,
delay,
promiseEvent,
parallel
};
2 changes: 1 addition & 1 deletion rpc.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const {Dispatcher, Base36Namer} = require("./command-dispatcher");
const Future = require("./future");
const {Future} = require("./future");

class RPCClient {
constructor(input, output) {
Expand Down
17 changes: 10 additions & 7 deletions sequence.js
Original file line number Diff line number Diff line change
@@ -1,15 +1,18 @@
const Future = require('./future')
const assert = require('assert')
/**
* An abstraction around time bound delayed execution of a series of promises.
*/
const {Future} = require('./future');
const assert = require('assert');

class Sequence {
constructor( initialValue = true ) {
const when = new Future()
const when = new Future();
when.accept(initialValue);
this.last_op = when.promised;
}

next( perform ){
assert.equal(typeof perform, "function")
assert.equal(typeof perform, "function");
const operation = this.last_op.then(( input ) => {
return perform( input )
});
Expand All @@ -25,16 +28,16 @@ class Sequence {
canceled = true;
fail()
}
})
});
this.next( (input) => {
if( canceled ){ return input; }
waiting = false;
clock.cancel(token)
clock.cancel(token);
return perform( input )
});
}
}

module.exports = {
Sequence
}
};
2 changes: 1 addition & 1 deletion sockets.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
const Future = require("./future");
const {Future} = require("./future");

/**
* Abstracts out how to retrieve an address of a socket when being bound as a listener. The resulting socket is the
Expand Down
2 changes: 1 addition & 1 deletion streams.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
const Future = require("./future");
const {Future} = require("./future");

const {Readable, Transform, Writable} = require("stream");
const {LengthPrefixedFrameIngress, LengthPrefixedFrameEgress} = require("./streams/network-length-frame");
Expand Down
2 changes: 1 addition & 1 deletion tests/future-tests.js
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
const mocha = require("mocha")
const assert = require("assert")
const Future = require("../future")
const {Future} = require("../future");


describe( "Future", function () {
Expand Down
2 changes: 1 addition & 1 deletion tests/sequence-tests.js
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ const mocha = require("mocha")
const assert = require("assert")

const {Sequence} = require('../sequence')
const Future = require('../future')
const {Future} = require('../future');

describe("Sequence", function () {
it("initial value is passed to first in sequence", async function(){
Expand Down
2 changes: 1 addition & 1 deletion tests/spool-tests.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
const mocha = require("mocha")
const assert = require("assert")

const Future = require("../future")
const {Future} = require("../future");
const {Sequence} = require('../sequence')
const {LogicalTimer, WatchDog, defaultNodeTimer} = require("../timers")

Expand Down
2 changes: 1 addition & 1 deletion timers.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
const Future = require('./future')
const {Future} = require('./future');
const assert = require('assert')

class LogicalTimerAlarm {
Expand Down

0 comments on commit 3915201

Please sign in to comment.