Pourquoi le modèle plat ne provoque-t-il pas de réductions en aval du feu? J'ai eu un code comme: handleFiles.flatMap(files => Rx.Observable.from(files). flatMap((file, i) => fileReader(file, i)). reduce((form, file, i) => { form.append('file[' + i + ']', result); console.log('reduce step', file); return form; }, new FormData()). tap(console.log.bind(console, 'after reduce')) ). subscribe(console.log.bind(console, 'response')); Et le problème est […]
Pour s'amuser et apprendre, j'essaie de mettre en œuvre un système d'annulation dans mon application en utilisant une programmation fonctionnelle réactive. J'ai un flux de changements d'état, qui doivent être sauvegardés sur la pile d'annulation. Lorsque l'utilisateur clique sur annuler, je prends une valeur de la pile et met à jour l'état de l'application en […]
Cet exemple de tampon RxJava (avec tableau de marbre !) Décrit parfaitement le résultat souhaité: Collecter des éléments dans des tampons pendant les périodes de rafale et les émettre à la fin de chaque éclatement, en utilisant l'opérateur de rebondissement pour émettre un indicateur de fermeture de tampon sur l'opérateur de tampon Éditer: après avoir […]
Je suis novice dans la programmation réactive et je recherche avec cycle.js, en essayant de mettre en œuvre quiconque suit la boîte de ce didacticiel . Mais j'ai compris que pour une bonne mise en œuvre (et des fins d'apprentissage), je n'ai pas une seule donnée: nom d'utilisateur complet. Je peux l'obtenir en obtenant séquentiellement […]
J'ai lu sur le FRP et j'étais très excité. Il semble génial, donc vous pouvez écrire plus de code de haut niveau, et tout est plus composable, etc. Ensuite, j'ai essayé de réécrire mon propre petit jeu avec quelques centaines de sloc de js simple à Bacon. Et j'ai constaté qu'au lieu d'écrire un code […]
En JavaScript, le modèle d'observateur est utilisé assez souvent. Il y a une chose délicate et ce sont les références que le sujet conserve des observateurs. Ils nécessitent un nettoyage. Pour les applications régulières, j'utilise les règles suivantes: Si le sujet a une durée de vie plus courte que (ou égale à) l'observateur, je peux […]
Je suis toujours en train de trouver des programmes réactifs, donc je suis très sûr que ce soit très basique, mais le nombre de transformations de flux est assez écrasant pour un débutant. Je crée un événement Observable à partir d'un événement DOM. Cet événement devrait à son tour déclencher un appel REST et tous […]
J'utilise Rx.js pour traiter le contenu d'un fichier, faire une requête http pour chaque ligne puis agréger les résultats. Cependant, le fichier source contient des milliers de lignes et je surcharge le HTTP HTTP distant auquel je suis en train d'effectuer la requête http. Je dois m'assurer d'attendre la demande HTTP existante pour rappeler avant […]
Quelqu'un peut-il donner une définition claire avec un exemple simple qui explique ce qu'est un "rappel d'enfer" pour quelqu'un qui ne connaît pas javascript et node.js? Quand (dans quel type de paramètres) est-ce que le «problème de retour de l'enfer» se produit? Pourquoi cela se produit-il? Est-ce que le «rappel d'enfer» est toujours lié aux […]
J'ai examiné la question SO suivante: Quels sont les observables à chaud et à froid? Résumer: Un observé froid émet ses valeurs quand il a un observateur pour les consommer, c'est-à-dire que la séquence des valeurs reçues par les observateurs est indépendante du temps d'abonnement. Tous les observateurs consommeront la même séquence de valeurs. Un […]