Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 | 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x 9x | const {FlowAll} = require('./flows/all.js');
const {FlowOne} = require('./flows/one.js');
const {FlowEach} = require('./flows/each.js');
const {FlowJoin} = require('./flows/join.js');
const {FlowHold} = require('./flows/hold.js');
const {FlowFirst} = require('./flows/first.js');
const {FlowWait} = require('./flows/wait.js');
const {Goal} = require('./goals/goals.js');
const {DataWrapper} = require('./wrapper/data_wrapper.js');
const {Manager} = require('./manager/manager.js');
const {Rule} = require('./rules/rules.js');
// const {RuleGroup} = require('./rules/group.js');
const {DuplexWrapper} = require('./wrapper/duplex.js');
const {ReadableWrapper} = require('./wrapper/readable.js');
const {TransformWrapper} = require('./wrapper/transform.js');
const {WritableWrapper} = require('./wrapper/writable.js');
/**
* Condition function for flowing to a stream
* @callback Condition
* @param {(DataWrapper|any)} payload chunk that's flown through the stream
* @returns {boolean} if true, condition is accepted and data is flown to stream
*/
/**
* Payload processing method
* @callback Process
* @param {(DataWrapper|any)} payload chunk that's going to be processed somehow
*/
/**
* Thenable function
* @callback Then
* @param {(DataWrapper|any)} payload chunk that's going to be processed somehow
* @returns {Promise}
*/
/**
* Thenable function
* @callback Catch
* @param {(DataWrapper|any)} error error message
* @returns {Promise}
*/
/**
* Returns the identity of a message. It could be an internal id, or an id of a wrapped message.
* @callback Identify
* @param {(DataWrapper|any)} payload chunk that's flown through the stream
* @returns {any} identity of the message
*/
/**
* Node style callback
* @callback NodeCallback
* @param {any} error
* @param {any} data
*/
/**
* Process rules. You may emit events to send data to streams.
* @callback RuleProcess
* @param (DataWrapper|any)} payload chunk that's flown through the stream
* @returns {boolean|any|undefined}
*/
module.exports.FlowAll = FlowAll;
module.exports.FlowOne = FlowOne;
module.exports.FlowEach = FlowEach;
module.exports.FlowHold = FlowHold;
module.exports.FlowJoin = FlowJoin;
module.exports.FlowFirst = FlowFirst;
module.exports.FlowWait = FlowWait;
module.exports.Goal = Goal;
module.exports.DataWrapper = DataWrapper;
module.exports.sfc = Manager;
module.exports.Rule = Rule;
// module.exports.RuleGroup = RuleGroup;
module.exports.Duplex = DuplexWrapper;
module.exports.Readable = ReadableWrapper;
module.exports.Transform = TransformWrapper;
module.exports.Writable = WritableWrapper;
|