tx.push(rotated)
}
Am Montag, 23. November 2015 12:33:28 UTC+1 schrieb Akka Team:
>
> Hi Muki,
>
>
>
> On Sun, Nov 22, 2015 at 4:49 PM, Muki <nepomuk...@gmail.com >
> wrote:
>
>> Hi,
>>
>&
aterialized value inside the Graph"
<http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/stream-graphs.html#Accessing_the_materialized_value_inside_the_Graph>,
but couldn't figure out how to implement this kind of pattern.
Thanks in advance,
Muki
--
>>
Hi,
I implemented a working solution and will soon provide it as an activator
template.
https://github.com/muuki88/akka-http-elasticsearch
cheers,
Muki
Am Freitag, 2. Oktober 2015 17:29:09 UTC+2 schrieb Muki:
>
> Hi,
>
> I'm playing around with akka-http and elasti4s reactive e
)
println(result)
system.shutdown()
system.awaitTermination()
}
which is not working as expected. I'm not sure where I'm messing things up.
The order of operations *concat -> groupBy ( and fold) -> flatten* don't
seem to work.
thanks,
Muki
--
>>>>>&g
concat)
.fold[TrajectoryBoxes](TrajectoryBoxes(Nil))(_ :+ _)
cheers,
Muki
Am Dienstag, 22. September 2015 11:41:50 UTC+2 schrieb Patrik Nordwall:
>
> Have you looked at flatten (concat)?
> /Patrik
>
> On Sun, Sep 20, 2015 at 2:57 PM, Muki <nepomuk...@gmail.com >
> wrote
.mapAsync(parallelism = 1) { polygon =>
val sink = Sink.fold[Seq[RichSearchHit],
RichSearchHit](Seq.empty[RichSearchHit])(_ :+ _)
source(polygon).runWith(sink)
}
thanks in advance,
Muki
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
compatibility, etc.)
I'm really interested in other user suggestions :)
cheers,
Muki
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Search the archives: https://groups.google.com/group/akka-user
---
You received
-cluster-sample
cheers,
Muki
Am Dienstag, 9. Dezember 2014 20:08:03 UTC+1 schrieb kraythe:
Greetings,
I have a question about the interaction of play and Akka in a cluster.
Assume I have an actor that sends asynchronous notifications over a web
socket using Atmosphere framework (yes I
,
Muki
Am Donnerstag, 4. Dezember 2014 18:08:30 UTC+1 schrieb rkuhn:
Dear hakkers,
we are very pleased to announce the availability of the first milestone
release of the upcoming Akka Streams and Akka HTTP modules. The
significance of this milestone is that we have roughly reached feature
options I see don't look ideal to me
class GridCellTransformer {
def apply(update: LocationUpdate): Seq[IndexedLocationUpdate] = Nil
}
val t = new GridCellTransformer
geoSource.map(t.apply)
or
geoSource.map {
val buffer = ...;
x = toIndexed
}
thanks :)
Muki
--
Read the docs: http
Compressor(…))
Does that help? :-)
On Sun, Nov 16, 2014 at 8:44 PM, Muki nepomuk...@gmail.com javascript:
wrote:
Hi,
I'm currently trying to build a real-time geo-indexing application with
akka streams.
In order to index my location updates I have to buffer them in a
Transformer and
map them
in
overengineering stuff you actually
can solve a lot easier. Maybe it's a nice starter for beginners as you
mentioned.
thanks again,
Muki
PS: Yeah, I'll try to pull an activator out of this
Am Donnerstag, 31. Juli 2014 09:52:34 UTC+2 schrieb Michael Pisula:
Hi Muki,
I like the pattern. In details I
around typed actors.
cheers,
Muki
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google
Hi Martynas,
Thanks a lot for taking some time to go through my code. I just published
the activator
template
play-akka-cluster-sample
http://typesafe.com/activator/template/play-akka-cluster-sample
cheers,
Muki
Am Freitag, 11. Juli 2014 12:22:39 UTC+2 schrieb Martynas Mickevičius:
Hi
Hi,
I finished the first prototype for my activator template:
https://github.com/muuki88/activator-play-cluster-sample
If you have any feedback regarding does/donts and best-practices
on the cluster configuration, I would change this before publishing as
an activator.
thanks,
Muki
Am
* actor.
thanks,
Muki
Am Montag, 7. Juli 2014 23:02:16 UTC+2 schrieb Muki:
Hi,
I'm currently starting to learn more about akka's cluster feature.
My goal is to have separate frontend and backend which are part
of the same cluster, so I can
- Start jobs on backend akka-nodes from
use remoting instead of clustering?
I tried solution number 1, but the websocket actors couldn't be created,
because *ActorRefClusterProvider*
wasn't configured (but it's in the config, when I log it via
system.logConfiguration).
thanks for any advice,
Muki
--
Read the docs: http
@Giovanni it could be the idle status in my case, too. My app is rarely used
and I have an actor per shard, which makes them even less used.
@Roland This is an interesting point. My setup is very basic. No cluster, no
extra config, not even high-load and still there's a chance of loosing reply
18 matches
Mail list logo