- From: guest271314 <notifications@github.com>
- Date: Sat, 19 Aug 2017 18:33:26 -0700
- To: whatwg/streams <streams@noreply.github.com>
- Cc: Subscribed <subscribed@noreply.github.com>
Received on Sunday, 20 August 2017 01:33:48 UTC
@domenic A variation of your code from jsbin which logs the order `writable` closed -> `readable` closed
```
function pipeThrough(data) {
"use strict";
console.clear();
let readable;
let writable = new WritableStream({
write(chunk) {
readable = new ReadableStream({
pull(c) {
c.enqueue(chunk);
c.close();
}
})
},
close(c) {
console.log("done")
}
});
let writer = writable.getWriter();
writer.write(data);
writer.close();
return writer.closed.then(() => {
console.log("really done");
return readable
});
}
pipeThrough([1, 2, 3])
.then(reader => {
let stream = reader.getReader();
let fn = ({value,done}) => {
if (done) return stream.closed.then(() => ({done}));
console.log(value, done);
return stream.read().then(fn)
}
return stream.read().then(fn)
})
.then(done => console.log(done));
```
--
You are receiving this because you are subscribed to this thread.
Reply to this email directly or view it on GitHub:
https://github.com/whatwg/streams/issues/765#issuecomment-323557537
Received on Sunday, 20 August 2017 01:33:48 UTC