isaacs
dbcacc5afe
streams2: NextTick the emit('readable') in resume()
Otherwise resume() will cause data to be emitted before it can be handled.
12 years ago
isaacs
99021b7a4f
streams2: pause() should be immediate
12 years ago
isaacs
42981e2aad
streams2: Switch to old-mode immediately, not nextTick
This fixes the CONNECT/Upgrade HTTP functionality, which was not getting
sliced properly, because readable wasn't emitted on this tick.
Conflicts:
test/simple/test-http-connect.js
12 years ago
isaacs
83704f1279
streams2: Set readable=false on end
12 years ago
isaacs
d58f2654bc
streams2: Unpipe on dest.emit('close')
12 years ago
isaacs
49ea653363
streams2: Remove pipe if the dest emits error
12 years ago
isaacs
ac5a185edf
streams2: Handle pipeChunkSize properly
12 years ago
isaacs
53fa66d9f7
streams2: Set 'readable' flag on Readable streams
12 years ago
isaacs
4b4ff2dff1
streams2: Refactor out .once() usage from Readable.pipe()
12 years ago
isaacs
38e2b0053a
streams2: Get rid of .once() usage in Readable.pipe
Significant performance impact
12 years ago
isaacs
b15e19a232
streams2: Remove function.bind() usage
It's too slow, unfortunately.
12 years ago
isaacs
2ff499c022
streams2: Do multipipe without always using forEach
The Array.forEach call is too expensive.
12 years ago
isaacs
286c54439a
streams2: Only emit 'readable' when needed
12 years ago
isaacs
62dd04027b
streams2: Set Readable lwm to 0 by default
12 years ago
isaacs
f20fd22abd
streams2: Add high water mark for Readable
Also, organize the numeric settings a bit on the ReadableState class
12 years ago
isaacs
63ac07b32b
streams2: Export Readable/Writable State classes
12 years ago
isaacs
286aa04910
streams2: Abstract out onread function
12 years ago
isaacs
f624ccb475
streams2: Use StringDecoder.end
12 years ago
isaacs
cf0b4ba410
streams2: flow() is not always bound to src
12 years ago
isaacs
545f512619
streams2: ctor guards on Stream classes
12 years ago
isaacs
8acb416ad0
streams2: Handle immediate synthetic transforms properly
12 years ago
isaacs
02f017d24f
streams2: Allow 0 as a lowWaterMark value
12 years ago
isaacs
3b59fd70f4
streams2: Make Transform streams pull-style
That is, the transform is triggered by a _read, not by a _write.
This way, backpressure works properly.
12 years ago
isaacs
9b5abe5bfe
streams2: setEncoding and abstract out endReadable
12 years ago
isaacs
51a52c43a2
streams2: Set flowing=true when flowing
12 years ago
isaacs
420e07c577
streams2: The new stream base classes
12 years ago