The rsult is not correct, in problem 7 about stream-adventure

[ntilwalli]

I'm experiencing the same problem.

[mvolkmann]

I think it will work if you change this line:
req.pipe(th).pipe(res);
to this:
req.pipe(th).pipe(res).end();

If that's the case then I think the solution that is output when you get it to pass is incorrect.

[MrNice]

Hey, I figured it out. The correct solution would be:

var makeTransformer = function() {
  return through(function (buffer) {
    this.queue(buffer.toString().toUpperCase());
  });
};

var server = http.createServer(function (req, res) {
  if (req.method === 'POST') {
    var transformer = makeTransformer();
    req.pipe(transformer).pipe(res);
  }
  else res.end('send me a POST\n');
});

Here I have a makeTransform function which returns a read/write through stream (a transform stream). I use it to create a new through-stream for every request and response pair.

This is necessary because when the first request (mostly) succeeds, it 'uses up' the through stream you instantiated. I discovered this by logging out the this context within the through stream's write handler. On the first request, it's still writeable and readable. But as soon as the request object emits an end event, the through stream closes.

@Substack is this accurate?

[kalinchernev]

I allow myself to close this one as it's 2 years old, the APIs has changed, and the working solution is provided.