rxjs 5.5 管道 fs readdir 事件

Question

我想使用 rxjs 样式读取目录，但我无法让它工作

import { readdir } from 'fs';
import { bindNodeCallback } from 'rxjs/observable/bindNodeCallback'; 
import { tap } from 'rxjs/operators';

function test() {

  bindNodeCallback(readdir).pipe(
    tap((x: any) => console.log(x))
  ).subscribe();
}

test();

bindNodeCallback 似乎不能 pipable，有什么想法吗？

我正在使用 rxjs@5.5.2

Answer 1

您需要以某种方式传递您要读取的目录的名称。 BindNodeCallback returns 一个函数，您必须调用该函数才能获得可观察对象。

如果您将 bindNodeCallback 与 readdir 一起使用，那么您必须执行类似

的操作

bindNodeCallback(readdir)(dirName).pipe(....)

其中 dirName 是包含您要读取的目录名称的字符串。

您可能会在本文中找到更多详细信息https://medium.freecodecamp.org/rxjs-and-node-8f4e0acebc7c

rxjs 5.5 管道 fs readdir 事件

rxjs 5.5 pipe fs readdir event

fs

rxjs

typescript

rxjs5