Comments (4)
Thats because you dump all data to on('data', function () { ... })
, this is not an issue with got
. Use through2
to peek into stream.
from got.
Hmm, I just tried to add a a through2 transform to my pipeline that just passes data through and I still go no output when using got.stream
but works fine with request
. Sorry, I'm just getting into using streams so it might be something simple.
var MultiStream = require('multistream')
var through2 = require('through2')
var got = require('got')
var request = require('request')
var count = 0;
function factory (cb) {
if (count > 3) return cb(null, null)
count++
var stream = got.stream('https://www.random.org/integers/?num='+count+'&min=1&max=6&col=1&base=10&format=plain&rnd=new')
// var stream = request('https://www.random.org/integers/?num='+count+'&min=1&max=6&col=1&base=10&format=plain&rnd=new')
stream.pipe(through2(function (chunk, enc, callback) {
this.push(chunk)
callback()
}))
setTimeout(function () {
cb(null, stream)
}, 100)
}
MultiStream(factory).pipe(process.stdout);
from got.
Try this:
stream = stream.pipe(through2(function (chunk, enc, callback) {
this.push(chunk)
callback()
}))
from got.
@floatdrop Thanks, that worked. It's odd that request
works without setting the stream instance back onto the same variable. I tested with fs.createReadStream
and it behaves like got.stream
. Thanks again for your help.
from got.
Related Issues (20)
- Back-port of CVE fix HOT 2
- ECONNEREFUSED or ENOTFOUND crashes the application HOT 2
- Connect timeout fired even though underlying socket is actually connected
- typing issue HOT 2
- Errors on build proccess
- RequestError: unexpected end of file HOT 5
- Every other request library sends headers, except GOT. What am I doing wrong? HOT 3
- Inconsistent types for agent option
- Outdated How to store options section?
- Switch proxy before retry?
- unexpected output to console from post
- The requested module 'get-stream' does not provide an export named 'buffer'
- tsc can't resolve types for got 13 HOT 40
- Incorrect types on hook options?
- Why does the HTTPError constructor only use three fields of the PlainResponse HOT 1
- Got breaks when secure renegotiation is not supported by remote resource
- Wrong type for retry option HOT 1
- `afterResponse` hook throws error on an endpoint that returns `null` when setting `responseType: 'json'`
- GOAWAY/Stream error retries not working consistently
- Catch ECONNREFUSED Error HOT 5
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from got.