Skip to content

v0.4.0

Choose a tag to compare

@adam-fowler adam-fowler released this 15 Feb 10:42
· 110 commits to main since this release
9d04591
  • HBRequestBodyStreamer.consume returns one ByteBuffer as a time instead of an array
  • If response streamer receives an error send an .end
  • Fixed some issues with request streamer by creating promise for each ByteBuffer, instead of just the one for the whole array
  • Added back pressure on request streamer based on how much data is inflight.
  • Added HBRequestBodyStreamer.consumeAll(on:_) which takes a closure to process each ByteBuffer
  • Close channel when we receive a quiesce event
  • Channel initializer is supplied with the full array of child handlers instead of just the responder