Wie mock-streams in NodeJS

Ich versuche, unit-Tests einer meiner node-js-Module, die sich stark in strömen. Ich versuche zu verspotten, einen stream (die ich schreib), wie in meinem Modul habe ich ".auf('data/Ende)" zu-Hörer möchte ich gerne auslösen. Im wesentlichen möchte ich in der Lage sein, so etwas zu tun:

var mockedStream = new require('stream').readable();

mockedStream.on('data', function withData('data') {
  console.dir(data);
});

mockedStream.on('end', function() { 
  console.dir('goodbye');
});

mockedStream.push('hello world');
mockedStream.close();

Diese führt, aber der " on " - Ereignis wird nie ausgelöst nachdem ich die push und .close() ist ungültig).

Alle Hinweise, die ich finden kann auf streams verwendet das 'fs' oder 'net' Bibliothek als Grundlage für das erstellen eines neuen Streams (https://github.com/substack/stream-handbook), oder Sie verspotten ihn mit sinon aber der Spott wird sehr lange sehr quicky.

Ist es ein schöner Weg, um eine dummy-stream so?

InformationsquelleAutor flacnut | 2015-10-15
  1. 15

    Statt mit Push, ich hätte mit ".emittieren(<Fall>, <Daten>);"

    Meiner Pseudo-code funktioniert nun und sieht wie folgt aus:

    var mockedStream = new require('stream').Readable();
mockedStream._read = function(size) { /* do nothing */ };

myModule.functionIWantToTest(mockedStream); //has .on() listeners in it

mockedStream.emit('data', 'Hello data!');
mockedStream.emit('end');
    • Korrektur: new require('stream').Readable() (Hinweis Hauptstadt R)
    • erforderlich ist nicht ein Konstruktor, dieser wird Arbeit w/o das neue keyword
    InformationsquelleAutor flacnut
  2. 6

    Den accept-Antwort ist nur teilweise richtig. Wenn alles, was Sie brauchen, ist, Ereignisse zu feuern, mit .emit('data', datum) ist okay, aber wenn Sie brauchen, um Rohr diese mock-stream überall sonst funktioniert es nicht.

    Spott einen Lesbaren stream ist überraschend einfach, erfordert nur die Lesbaren lib. 

      let eventCount = 0;
  const mockEventStream = new Readable({
    objectMode: true,
    read: function (size) {
      if (eventCount < 10) {
        eventCount = eventCount + 1;
        return this.push({message: `event${eventCount}`})
      } else {
        return this.push(null);
      }
    }
  });

    Jetzt können Sie Rohr diese stream, wo und 'Daten' und 'Ende' wird Feuer.

    Weiteres Beispiel aus der Knoten-docs:
    https://nodejs.org/api/stream.html#stream_an_example_counting_stream

    InformationsquelleAutor Julius Ecker
  3. 3

    Gibt es einen einfacheren Weg: stream.PassThrough

    Habe ich gerade gefunden, der Knoten ist sehr leicht zu übersehen stream.PassThrough - Klasse, die ich glaube, ist, was Sie suchen.

    Vom Knoten docs:

    Den stream.PassThrough-Klasse ist eine einfache Implementierung eines Strom-Transformation, die einfach Pässe die input-bytes über den Ausgang. Ziel ist es vor allem für die Beispiele und Tests...

    link zu Google docs

    Den code aus der Frage geändert:

    const { PassThrough } = require('stream');
const mockedStream = new PassThrough(); //<----

mockedStream.on('data', (d) => {
    console.dir(d);
});

mockedStream.on('end', function() {
    console.dir('goodbye');
});

mockedStream.emit('data', 'hello world');
mockedStream.end();   //  <-- end. not close.
mockedStream.destroy();

    mockedStream.push() funktioniert auch, aber als Buffer so dass Sie möglicherweise tun möchten: console.dir(d.toString());

    InformationsquelleAutor Taitu-lism
  4. 1

    Gebäude auf @flacnut 's Antwort, ich habe diese (in NodeJS 12+) mit Readable.from() zu konstruieren stream vorab mit Daten (Liste der Dateinamen):

        const mockStream = require('stream').Readable.from([
       'file1.txt',
       'file2.txt',
       'file3.txt',
    ])

    In meinem Fall wollte ich verspotte die stream-Dateinamen zurückgegeben, die von fast-glob.stream:

        const glob = require('fast-glob')
    //inject the mock stream into glob module
    glob.stream = jest.fn().mockReturnValue(mockStream)

    In der Funktion erprobt:

      const stream = glob.stream(globFilespec)
  for await (const filename of stream) {
    //filename = file1.txt, then file2.txt, then file3.txt
  }

    Funktioniert wie ein Charme!

    InformationsquelleAutor dthorpe
Schreibe einen Kommentar