[akka-user] Http proxy/tuneling with cachedHostConnectionPool

2017-11-21 Thread Jozsef Zsido
Hi, I'm trying to expand the following example and replace the flow with cachedHostConnectionPool https://gist.github.com/rklaehn/3aa3215046df2c0a7795 My problem is that I'm unable to write compilable code: val flow = Http(system).cachedHostConnectionPool[HttpResponse]("localhost", 56700)

Re: [akka-user] Streaming proxy/tunel on top of akka-http

2017-11-13 Thread Jozsef Zsido
You are completrly right. I have did something differenly somewhere when I tested last time with browser. My code also works fine without the test code. Thank you very mutch! On Monday, November 13, 2017 at 9:28:22 PM UTC+2, Jozsef Zsido wrote: > > yes, I try all the time with real b

Re: [akka-user] Streaming proxy/tunel on top of akka-http

2017-11-13 Thread Jozsef Zsido
yes, I try all the time with real browser. The code blows up the memory when I download a 2GB file and try to stream it from one response to another -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] Streaming proxy/tunel on top of akka-http

2017-11-12 Thread Jozsef Zsido
Hi After disabling the content-length limit I get OutOfMemory error. That clearly means that akka-http reads the entire response into memory which is not desired in my case. Since I don't try to read the entity, this could be considered a bug? I tried to reconstruct the response object in

Re: [akka-user] Streaming proxy/tunel on top of akka-http

2017-11-08 Thread Jozsef Zsido
Hi, Not much code I have, basically I took a sample for akka-http proxy: https://gist.github.com/kovacshuni/afb7d53f40f501d0ab82 trait BrowseServerRoutes3 { implicit val system = ActorSystem("Browse") implicit val materializer = ActorMaterializer() implicit val ec = system.dispatcher

[akka-user] Streaming proxy/tunel on top of akka-http

2017-11-07 Thread Jozsef Zsido
Hi, I'm trying to write an akka-http based service which tunels some of the requests through a given (ip,port). The basics are working propely but I have problem when I try to download large files. akka-http tries to load the complete response as Entity and does not streams trully. My