Ross A. Baker

I can see this error the http4s-async-http-client binding under load. `complete` is not reliably called, which causes `removeFromPipeline` to be missed. I made it run clean by removing the `NAME_IN_CHANNEL_PIPELINE`...

Reading your issue again, the focus is on the `Connection reset by peer`. I've been chasing (and reliably reproducing) the `request-body-streamer` error. I'll open a new issue for that. Sorry...

My solution has revealed a new problem: ```scala [error] java.lang.IllegalStateException: unexpected message type: DefaultHttpRequest, state: 1 (HttpObjectEncoder.java:86) [error] io.netty.handler.codec.http.HttpObjectEncoder.encode(HttpObjectEncoder.java:86) [error] io.netty.handler.codec.http.HttpClientCodec$Encoder.encode(HttpClientCodec.java:167) [error] io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:89) [error] io.netty.channel.CombinedChannelDuplexHandler.write(CombinedChannelDuplexHandler.java:348) [error] io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738) [error] io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730) [error]...

Sorry, I cleaned up my GitHub a while back, and don't have that repo anymore.

mvnrepository.com has some reverse index, but I think it is only to the version level. Keyed by artifact would be more valuable for this purpose. I also don't see evidence...

I don't think there is likely to be a universal solution, but we could probably do something on certain backends. The blaze pipeline factory [creates the `SSLEngine` from the `engineConfig`](https://github.com/http4s/http4s/blob/0e1d6f3a3bf3009909207007d05e5a3efb9394e4/blaze-server/src/main/scala/org/http4s/server/blaze/BlazeServerBuilder.scala#L308)....

Oh, interesting! So instead of proxying with some generic wrapper like `Eval` or `AtomicReference`, this proxies by implementing the interface directly. That sounds like it might work on all our...

Nice solution. I don't imagine we'd want http4s-server to have a hard dependency on that kickstart library, but an example would be a worthy addition to the docs.

We don't currently a decoder to a `Process`. We can decode the entity to a `Task[Process[Task,_]]`, but, eh?

First off, since the above comment is old, `Process` is `Stream` and `Task[Process[Task, _]]` is `F[Stream[F, _]]`. But there still exists no `EntityDecoder` to a `Stream`. And maybe there doesn't...