PUT/POST long running request and streaming body data

[alm...@googlemail.com]

Hi,
I'm trying to call a WS using dispatch which will establish a long running connection (very much like twitters firewhose endpoint)
When connected, I need to stream body data from a (possibly endless) input stream.

I tried to use nings InputStreamBodyGenerator but it looks like it doesnt send the data of the inputstream immediatelly over the wire.

Here's my sample code:
val req = url(myWSUrl).POST
req.subject.underlying(_.setBody(new InputStreamBodyGenerator(is)))
val futureResponse = Http(req > customAsyncHandler)

for debugging I simulate the WS endpoint using a netcat -l 8080 which prints the incoming request to stdout - it sends the requestheaders but no body data:

POST /debugendpoint HTTP/1.1
Host: localhost:1212
Connection: keep-alive
Accept: */*
User-Agent: Dispatch/0.11.0

any suggestions how to accomplish this ?
thanks & cheers
hanez

[Miles Spielberg]

Req.underlying returns a modified copy of the Req with the additional changes embedded. You need to capture the return value from req.underlying, and provide that to Http():

val req = url(myWSUrl).POST
val reqWithBody = req.underlying(_.setBody(new InputStreamBodyGenerator(is)))
val futureResponse = Http(reqWithBody > customAsyncHandler)

--
You received this message because you are subscribed to the Google Groups "Dispatch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to dispatch-scal...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[alm...@googlemail.com]

... which perfectly makes sense! :-)

Thanks for pointing this out Miles!