highland.js에 splitby 메서드를 사용하여 시작 및 끝 구분 기호 사이의 데이터를 추출하려고합니다. -----BEGIN DATA-----
MIIEzDCCArSgAwIBAgIVCugKYzMN5ra8zPWxYE8pUU9SxjYSMA0GCSqGSIb3DQEB
CwUAMHAxCzAJBgNVBAYTAkdCMRUwEwYDVQQIDA
highland.js에 문제가 있습니다. 스트림 데이터에서 함수의 배열을 만들어야하지만 제대로 작동하지 않습니다. 여기 내 코드가 있지만 requests은 항상 비어 있습니다. var requests = [];
_(fs.createReadStream("small.txt", { encoding: 'utf8' }))
.splitBy('-----
나는 각 요소가 GET 요청에 대한 약속 인 고원 스트림이 Promise { <pending> }
Promise { <pending> }
Promise { <pending> }
그러나 파이프 라인을 만들고 약속의 실제 결과에 대해 작업하고 싶습니다. (then 또는 await을 사용하고 싶지 않습니다.) 나는 스트림 파이프 라인을 통해 이러한 약속을
highland.js으로 프로그램을 작성하여 여러 파일을 다운로드하고 압축을 풀어 오브젝트로 변환 한 다음 오브젝트 스트림을 flatMap에 의해 하나의 스트림으로 병합하여 인쇄합니다. function download(url) {
return _(request(url))
.through(zlib.createGunzip())
.
안녕 사람과 행복한 공휴일! 고지대에서 csv 행의 스트림을 소비하려고합니다. 특수 처리를 수행하고 헤더를 스트림으로 전달하지 않으려면 .consume()을 호출하고 배열에서 결과를 원했습니다. 문제는 .toArray()의 콜백이 호출되지 않는다는 것입니다. 나는 이미 나의 해결책을 .map().toArray()으로 바꿨 기 때문에 이것에 대해서 궁금하다.
에 toCallback 포장 나는 같은 것을 쓰고 싶은 : const Promise = require('bluebird')
const H = require('highland')
Promise.fromCallback(
H([1, 2, 3]).toCallback
).then(function(val) {
expect(val).eql(1,
스트리밍 스트리밍 문자열이 highland입니다. 이제 외부 라이브러리 (내 경우 Amazon S3)에서이를 소비하려고하고 SDK의 경우 표준 노드 읽기 가능 스트림이 필요합니다. 고지 스트림을 ReadStream으로 변환하는 방법이 있습니까? 아니면 직접 변형해야합니까?
typescript @ 2 및 highlandjs 라이브러리를 사용하고 있습니다. 고원 입력은 mergeWithLimit(n) 기능이 누락되었습니다. 그것은 : 는 스트림의 스트림을 받아서 한 번에 실행 일시 중지 해제 스트림 할 수 의 수를 limitting하는 하나의 새로운 스트림에 자신의 가치와 오류를 병합합니다. 이제이 방법은 DefinitlyTyp
sourceStream은 BaseData 개의 개체로 구성되어 있습니다. 이 스트림을 n 개의 스트림으로 포크하고 각 스트림을 다른 스트림으로 바꾼 다음 각 스트림을 원하는대로 필터링하고 변환합니다. 마지막으로 n 개의 스트림에만 특정 유형이 포함되고 포크 된 스트림의 길이가 달라질 수 있습니다. 데이터는 향후 삭제되거나 추가 될 수 있습니다. { id: