createReadStreamで読み込み中止する。

Question

javascriptのcreateReadStreamで、endイベントが来る前に、ファイルを閉じて読み込むのを中止する方法はありますか？

const fs = require('fs');
fs.createReadStream('dummy.txt')
    .on('data', () => {
      //一行ずつ読み込む
    })
    .on('end', () => {
    });

Answer 1

NodeJS のストリームについては、まだまだ勉強中の身ですが…

let readData = '';

// 1）ストリームのインスタンスを得る
let instanceOfStream = fs.createReadStream("filename")
  .on('data', (buf) => {
    // 2) インスタンスのメソッドも使える
    // buf を読みつつ意図した条件下では readData に格納
    // 条件を外れると、格納中止 or instanceOfStream.end() を呼ぶ?
  })
  .on('end', () => {

  })

Readable のメソッドで使えるのがあれば使う。なければ使わずデータ抽出をやめるという例です。

NodeJSのドキュメント

• fs.createReadStream < Class: fs.ReadStream < Class: stream.Readable

が参考になりそうです。

ファイルサイズが大きいなど、パイプで別のストリームに渡したい場合
Transform Streams というのもあるみたいで、こちらは派生クラスを書く必要がありそうです。

冒頭の通り、未熟で確実なお答えを出せませんが、参考になればと思います。

Comments

[退会済みユーザー]

自分の環境はstream._events.end();
で停止可能でした。

[退会済みユーザー]

お陰さまでうまくいきました。
ありがとうございます。

[m.ts10806]

なぜ両方退会