typescript - 无法从 TypeScript 中的 Observable.bindNodeCallback(fs.readFile) 创建可观察对象

Question

我正在尝试使用 rxjs 5在 TypeScript 中编写 Node.js 服务器，但在将 fs.readFile 转换为其 rxjs 形式时遇到错误。我希望以下代码可以在 TypeScript 中运行

// This is a JavaScript example from the official documentation. It should
// also work at the TypeScript envrionment.

import * as fs from 'fs';
import { Observable } from 'rxjs';

let readFileAsObservable = Observable.bindNodeCallback(fs.readFile);

// This is the line that throws the error.
let result = readFileAsObservable('./roadNames.txt', 'utf8');

result.subscribe(x => console.log(x), e => console.error(e));

但是，当我添加第二个参数 'utf-8' 时，我的编辑器报告 TypeScript 错误

Supplied parameters do not match any signature of call target.

我试图找到有关如何在 rxjs 和 TypeScript 中使用 fs.readFile() 的指南，但运气不佳。

Answer 1

bindCallback 和 bindNodeCallback 对于 TypeScript 来说可能很棘手，因为这完全取决于 TypeScript 如何推断函数参数。

可能有更好的方法，但这就是我所做的，以准确了解所推断的内容:将可观察对象分配给完全不兼容的对象，并仔细查看受影响的错误。例如，这个:

const n: number = Observable.bindNodeCallback(fs.readFile);

将影响此错误:

Type '(v1: string) => Observable<Buffer>' is not assignable to type 'number'.

所以很明显，TypeScript 正在匹配 readFile 的仅路径重载。

在这种情况下，我经常使用箭头函数来准确指定我想使用的重载。例如，这个:

const n: number = Observable.bindNodeCallback((
  path: string,
  encoding: string,
  callback: (error: Error, buffer: Buffer) => void
) => fs.readFile(path, encoding, callback));

将影响此错误:

Type '(v1: string, v2: string) => Observable<Buffer>' is not assignable to type 'number'.

因此它现在匹配所需的重载并且以下将起作用:

let readFileAsObservable = Observable.bindNodeCallback((
  path: string,
  encoding: string,
  callback: (error: Error, buffer: Buffer) => void
) => fs.readFile(path, encoding, callback));

let result = readFileAsObservable('./package.json', 'utf8');
result.subscribe(
  buffer => console.log(buffer.toString()),
  error => console.error(error)
);