i, Feb 19, 2016 at 12:01 PM, Jeroen Rosenberg <jeroen.r...@gmail.com
> > wrote:
>
>> Thnx Endre for that swift reply.
>>
>> I've managed to upgrade to Akka 2.4.2 without any issues like you
>> expected. Could you please give me a small code sample of how to use thi
>
> On Fri, Feb 19, 2016 at 11:39 AM, Jeroen Rosenberg <jeroen.r...@gmail.com
> > wrote:
>
>> I'm using Akka Http and Akka streams 2.0.1 to process data from a
>> streaming HTTP API. For my usecase I need to make sure I shutdown (and
>> restart) my app
I'm using Akka Http and Akka streams 2.0.1 to process data from a streaming
HTTP API. For my usecase I need to make sure I shutdown (and restart) my
app in the following scenarios:
1. Client disconnect (connection is closed by something on my end)
2. I receive a zero byte chunk, which
like:
implicit val mapMarshaller: ToEntityMarshaller[Map[String, Any]] =
Marshaller.opaque { map =
HttpEntity(ContentType(MediaTypes.`application/json`), map.toString)
}
On Mon, Jul 27, 2015 at 2:07 PM, Jeroen Rosenberg jeroen.r...@gmail.com
javascript: wrote:
I'm trying to create
I'm trying to create a marshaller using Akka Http for a nested map that I
want to return as Json from my Http API together with an appropriate status
code. In the real code the map is coming from a service call that might
fail. I would like to determine the status code based on this service
That clarifies it. Thnx!
On Thursday, July 16, 2015 at 5:18:33 PM UTC+2, Johannes Rudolph wrote:
Hi Jeroen,
On Thu, Jul 16, 2015 at 4:35 PM, Jeroen Rosenberg
jeroen.r...@gmail.com javascript: wrote:
def gunzip(bytes: Array[Byte]) = {
val output = new ByteArrayOutputStream
graph
.map(byteString = gunzip(byteString.toArray()))
I replaced it with
.via(Gzip.decoderFlow)
Now it works :)
Thanks so much for your help!
On Thursday, July 16, 2015 at 4:24:11 PM UTC+2, Johannes Rudolph wrote:
Hi Jeroen,
On Thu, Jul 16, 2015 at 4:05 PM, Jeroen Rosenberg
jeroen.r
, Johannes Rudolph wrote:
Hi Jeroen,
it would be very helpful if you could somehow come up with a
reproducer against some publicly accessible endpoint which would show
the issue. It seemed to work for all the URLs I tested.
Johannes
On Wed, Jul 15, 2015 at 6:25 PM, Jeroen Rosenberg
I'm trying to connect to a third party streaming API over HTTPS using
akka-stream-experimental % 1.0-RC4 and akka-http-experimental %
1.0-RC4
My code looks like this
class GnipStreamHttpClient(host: String, account: String, processor:
ActorRef) extends Actor with ActorLogging {
this:
it).
Johannes
On Wednesday, July 15, 2015 at 4:13:14 PM UTC+2, Jeroen Rosenberg wrote:
I'm trying to connect to a third party streaming API over HTTPS using
akka-stream-experimental % 1.0-RC4 and akka-http-experimental %
1.0-RC4
My code looks like this
class GnipStreamHttpClient(host: String
wrong in akka http.
Jeroen
On Wednesday, July 15, 2015 at 5:01:32 PM UTC+2, Jeroen Rosenberg wrote:
Thnx Johannes for the swift reply :)
I'm using JDK 7. I strongly suspect the host I connect to (stream.gnip.com)
to be a virtual host (as they also provide other endpoints
Ok, that makes sense or at least is consistent
On Tuesday, May 26, 2015 at 12:08:54 PM UTC+2, Patrik Nordwall wrote:
On Tue, May 26, 2015 at 11:56 AM, Jeroen Rosenberg jeroen.r...@gmail.com
javascript: wrote:
Thnx! What will happen when I use Source.actorRef (as you suggested
Thnx! What will happen when I use Source.actorRef (as you suggested) with
OverflowStrategy.backpressure?
On Friday, May 22, 2015 at 4:08:41 PM UTC+2, Patrik Nordwall wrote:
On Thu, May 21, 2015 at 10:33 AM, Jeroen Rosenberg jeroen.r...@gmail.com
javascript: wrote:
I'm using Akka-Http 1.0
I'm using Akka-Http 1.0-RC2 and I'm building a simple streaming server
(Chunked HTTP) and client using reactive streams / flow graphs.
My server looks like this (simplified version):
object Server extends App {
implicit val system = ActorSystem(Server)
implicit val ec = system.dispatcher
the ~ operator from FlowGraphImplicits. Why can't this make the connection
implicitly?
On Friday, May 8, 2015 at 2:37:30 PM UTC+2, Akka Team wrote:
Hi Jeoren.
On Fri, May 8, 2015 at 2:03 PM, Jeroen Rosenberg jeroen.r...@gmail.com
javascript: wrote:
I'm trying to consume a stream from
I'm trying to consume a stream from a streaming API (based on akka-http and
akka-streams 1.0-RC2). I'm currently using spray client, since I couldn't
figure out how to do it with Akka Http client yet, but this is another
topic (some pointers are appreciated, though). Anyway, I'm creating a
16 matches
Mail list logo
