jiapengyu
21 lines
513 B
JavaScript
21 lines
513 B
JavaScript
import { Stream } from "stream";
|
|
import { PassThrough } from "readable-stream";
|
|
import { isStream } from "is-stream";
|
|
|
|
export function normalizeInputSource(source) {
|
|
if (source === null) {
|
|
return Buffer.alloc(0);
|
|
} else if (typeof source === "string") {
|
|
return Buffer.from(source);
|
|
} else if (isStream(source) && !source._readableState) {
|
|
var normalized = new PassThrough();
|
|
source.pipe(normalized);
|
|
return normalized;
|
|
}
|
|
return source;
|
|
}
|
|
|
|
export default {
|
|
normalizeInputSource,
|
|
};
|