HI,
I would like to use Akka Http client to call a webservice in a non blocking
way.
The app that will use this client must never block and should never crash,
even if the webservice that it will call becomes very slow (for example if
the traffic is too high).
When the client registers a
Hi,
Source.queue seems perfect to push elements dynamically into a source.
I am using Akka Streams 2.0 with Play framework (2.5-M2).
In Play 2.5, the controller's 'chunked' method can take an Akka Streams
Source to stream elements to the browser.
In other words Play defines its own Sink and I
Sorry in fact it's working good, but I'm still wondering if there is a
simpler/better way to achieve this, without using a Publisher?
Thanks
Loïc
Le samedi 6 février 2016 10:58:40 UTC+1, Loïc Descotte a écrit :
>
> Hi,
>
> Source.queue seems perfect to push elements dynamically i
Sorry for the useless thread it was a buffering problem on the browser side
:)
Le samedi 30 janvier 2016 08:51:32 UTC+1, Loïc Descotte a écrit :
>
> Hi,
>
> In Play 2.5 Akka Stream is the default stream processing library.
>
> I don't know if it's a Play or an Akka Stream pr
Hi,
In Play 2.5 Akka Stream is the default stream processing library.
I don't know if it's a Play or an Akka Stream problem, I'm trying to
stream some messages with an Akka Stream Source from a Play controller :
def timeline(keyword: String) = Action {
val source =
Hi,
I have an ActorPublisher and I'm building a source from it :
val source = Source.actorPublisher[TweetInfo](Props[TweetPublisher])
I need to send new elements into this source dynamically so I want an actor
ref.
On the last documentation (1.0-RC3), I've seen that I can do it this way :
The old way is still working, so I can fix my problem like that :
val actorRef = system.actorOf(Props[TweetPublisher])
val pub = ActorPublisher[TweetInfo](actorRef)
val source = Source(pub)
Le mercredi 17 juin 2015 14:24:55 UTC+2, Loïc Descotte a écrit :
Hi,
I have an ActorPublisher and I'm
