Articles of stream

Comment obtenir un onFinish unifié à partir de stream séparés (certains créés à partir du stream d’origine)

J’ai un processus de stream comme ceci: Incomming file via HTTP (original stream) -> Check if zipfile – Yes -> push through an unzip2-stream – No -> push to S3 Lorsque le stream unzip2 trouve des entrées zip, celles-ci sont poussées dans la même chaîne de stream, c.-à-d. Incomming file entry from zip file (“child” […]

nodejs event stream définissant une variable par stream

J’ai un code qui crée un stream lisible. J’aimerais définir le nom du stream dans la méthode getStream. J’ai essayé de définir une propriété comme indiqué ci-dessous. Je suis en mesure d’accéder à la propriété dans la fonction onceFunction mais je ne peux pas accéder à la propriété dans la carte Dites-moi ce que je […]

NodeJs: Comment canaliser deux stream dans un processus stdin (c.-à-d. Ffmpeg) généré, aboutissant à une seule sortie

Pour convertir les fichiers audio PCM en MP3, j’utilise les éléments suivants: function spawnFfmpeg() { var args = [ ‘-f’, ‘s16le’, ‘-ar’, ‘48000’, ‘-ac’, ‘1’, ‘-i’, ‘pipe:0’, ‘-acodec’, ‘libmp3lame’, ‘-f’, ‘mp3’, ‘pipe:1’ ]; var ffmpeg = spawn(‘ffmpeg’, args); console.log(‘Spawning ffmpeg ‘ + args.join(‘ ‘)); ffmpeg.on(‘exit’, function (code) { console.log(‘FFMPEG child process exited with code ‘ […]

Strongloop loopback-storage-service: comment utiliser StorageService.downloadStream () pour télécharger un ZIP de toutes les photos d’un conteneur?

J’utilise loopback-Component-Storage avec le fournisseur de système de fichiers pour télécharger des photos. Cela fonctionne très bien. Mais maintenant, j’ai une demande pour “exporter / télécharger” des photos dans une archive zip. J’ai mis en place du code pour append une autre méthode, downloadContainer() à Container partir de l’exemple de stockage de fichiers. Il utilise […]

La méthode onaddstream n’est pas exécutée après l’instanciation de l’object RTCPeerconnection

Chers amis, je suis en train de créer une application de test qui permet de connecter une fenêtre de navigateur à elle-même (en copiant les données vidéo de la caméra de l’utilisateur). Le résultat final est d’obtenir deux stream vidéo sur la page, l’un provenant directement de la caméra et l’autre venant depuis une connexion […]

Comment modifier un stream de requête en un nouveau stream de réponse dans HummusJS

Je dois injecter un fichier png dans un fichier PDF avec HummusJS. Dans la version de production de mon API, je recevrai une requête de publication contenant un base64 que je convertirai en stream de lecteur binary. (Dans l’exemple ci-dessous, j’utilise un test lu dans un fichier local.) Voici mon stream d’entrée de test (qui […]

Un symbole par stream temporel avec noeud

J’essaie d’implémenter un stream qui renvoie un symbole d’un fichier à chaque événement ‘data’. J’ai fini avec le code ci-dessous: var util = require(‘util’), fs = require(‘fs’), Readable = require(‘stream’).Readable; var util = require(‘util’); var Readable = require(‘stream’).Readable; var SymbolReadStream = function(filename, options) { Readable.call(this); this._readable = fs.createReadStream(filename, options).pause(); self = this; this._readable.on(‘readable’, function() { […]

Evénements pour fs createReadStream non appelés en permanence

J’ai un stream de fichiers fs utilisé pour les téléchargements de fichiers créés dynamicment. Je récupère ce stream et le redirige vers mon object de réponse après avoir défini les en-têtes appropriés. J’ai également défini quelques événements de stream pour que, en cas d’erreur ou de fin de stream, les fichiers générés soient supprimés du […]

Comment attendre un certain nombre d’octets dans un stream node.js?

J’ai un stream node.js lisible et je souhaite lire les 20 premiers octets et les traiter, en définissant un rappel pour les données traitées ou en recevant une promesse. Existe-t-il une fonction intégrée dans le noeud ou ailleurs dans NPM pour le faire? Par exemple, cela pourrait ressembler à quelque chose comme ça: var stream […]

est-il possible de réutiliser une chaîne de transformations de tuyaux dans NodeJS?

Par exemple si j’ai readableStream.pipe(ws1).pipe(ws2).pipe(ws3) Comment puis-je envelopper cette chaîne de transformation dans une seule fonction puis la réutiliser dans une autre chaîne de transformation? Je veux en faire comme ça: var transformationChain1 = readableStream.pipe(ws1).pipe(ws2).pipe(ws3) readableStream2.pipe(transformationChain1).pipe(endWs)