Estoy tratando de crear una versión de promesa o asíncrona/espera de los transductores. No estoy seguro de si los transductores deberían tener promesas o no, pero sé que necesito crear una versión de composición asíncrona. He probado todas las combinaciones posibles, pero nada me funciona.
Aquí hay una versión síncrona de componer/transductores:
// Compose function const compose = (...fns) => initialValue => fns.reduceRight((acc, fn) => fn(acc), initialValue); // Map and Filter transducers const mapTransducer = transform => reducer => (acc, value) => reducer(acc, transform(value)); const filterTransducer = predicate => reducer => (acc, value) => predicate(value) ? reducer(acc, value) : acc; // Reducers for Array.reduce const concatReducer = (acc, value) => acc.concat(value); // Could create push reducer for efficiency, but it doesn't matter at this point. // Client Usage const arr = [1, 2 3]; const results = arr.reduce( compose( filterTransducer(x => x > 1) )(concatReducer), [] ); // results: [2, 3]Versión asíncrona (incompleta):
const asyncCompose = (...fns) => { return initialValue => { return fns.reduceRight(async (promise, fn) => { const results = await promise; // the result of the promise is concatReducer // fn is the filterTransducer return fn(results); }, Promise.resolve(initialValue)); } }; // or const asyncCompose = (...fns) => { return initialValue => { return fns.reduceRight((promise, fn) => { return promise.then(fn) // but this doesn't make sense because the fn is filterTransducer, which isn't the same signature of promise.then method }, Promise.resolve(initialValue)); } }; // Client Usage const arr = [1, 2, 3]; const results = arr.reduce( asyncCompose( filterTransducer(x => x > 1) )(concatReducer), Promise.resolve([]) );Intenté ambos y uno a la vez sin resultados. Los transductores son difíciles de entender. Al componer funciones, el orden de las funciones que se ejecutan es de derecha a izquierda. Sin embargo, con Array.reduce y transductores, el orden cambia.