| interface Transducer<T, R> { | |
| (source: Iterable<T>): Iterable<R>; | |
| } | |
| class IterableTransductor<T> implements Iterable<T> { | |
| constructor( | |
| private readonly source: Iterable<T>, | |
| ) { | |
| } |
This is Promise-style wrapper (or layer, if you want) for event-channel. Why did I write this? Because I need to get promised calls through IPC-channel.
P.S. IPC is channel, which implementing EventEmitter interface and gives us a way to communicate between node-processes
| 'use strict' | |
| function denodeifySpecial (func, callBack) { | |
| return function () { | |
| let _this = this | |
| let len = arguments.length | |
| let args = new Array(len+1) | |
| for (let i = 0; i<len; i++) | |
| args[i] = arguments[i] | |
| return new Promise((resolve, reject)=> { |
| 'use strict' | |
| function Sync(fn,args) { | |
| return new Promise(function(resolve, reject) { | |
| let gen, call, callNext, callThrow | |
| call = function(isErr, arg) { | |
| let result | |
| try { | |
| if (isErr) | |
| result = gen.throw(arg) |