Hello,
like in topic. Does akka.io support unix sockets (AF_UNIX)?
I have a big server application wrote in Kylix, which I have started write
more than 15 years ago, and still is in heavy development. By a few last
years I created a few medium size apps in Scala / Akka, and I really like
I just had the rather gratifying experience of adding Snappy compression
using snappy-flows with
.via(SnappyFlows.compress)
For comparision purposes, and while I wait for snappy-flows to be updated
to 2.4.2, is there an equivalent built-in to akka-streams for GZip or other
compression algorithms
Hi Michael,
I have taken another approach. I already had a Send/Ack flow control over
the network. So I extended it to use the 'ask' and wait for the Ack from
the collecting actor in order to exersice back-pressure to the source.
Using blocking and bounded queue will also block the source after
Thanks Benoit for posting the explicit solution, that saved my some
headaches!
For anyone having similar issues like me: be aware that you need to import
the scala Future for the return type of the "handleGetTask" method, not the
Java future! Otherwise you'll get compilation errors regarding
It's not yet merged nor complete.
We'll focus on it after shipping 2.4.2 (tomorrow) and are hoping to include it
in 2.4.3,
timeline wise I can't promise anything though.
Hope this helps.
--
Cheers,
Konrad 'ktoso’ Malawski
Akka @ Typesafe
On 15 February 2016 at 16:58:46, Daniel Stoner
Thanks Konrad for the incredibly quick reply, I look forward to seeing the
new mechanisms.
By soon - what kind of timeline are you thinking?
At the moment we are prototyping a product in akka-http so we aren't
worried (at this stage at least) about production readiness too much and if
we have to
Hi Daniel,
Before I dive into your question I'd like to highlight that the Java directives
are undergoing an intense
rewrite just now (they're still experimental, so that's why we must do it now),
and will be way more elastic soon:
https://github.com/akka/akka/pull/19632/files?diff=unified
So
The current documentation for AkkaHttp directives:
http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0.3/java/http/routing-dsl/directives/index.html#directives-java
Says you can filter requests and modify requests/responses.
I'd love to be able to implement such a thing - but I've seen
Hi guys,
I'm trying to work out the following problem. Let me first describe the
scenario. I have an actor that loops over a specific set of numbers.
val someActor = system.actorOf(Props(new Actor {
var i = 1
def receive = {
case x: Int =>
log.info("Actor message is: " +
Hi.
I'm exploring Marshallers API and looking for the way to implement the
following:
- Get an instance of Aggregate in routes, e.g. a list of posts
- Provide a number of possible content-types for the Aggregate, e.g.
`application/agg+json`, `application/agg-with-user+json`
- For some of accept
Hi Matthieu,
Akka HTTP's low level is what it is – low level :-)
No, we don't provide any routing capabilities like this in the low level api.
Why don't you want to use the high level routing DSL? It has nice support for
those things built in.
If it's not an option, you can parse the Uri and
Hi,
I'm trying to figure out of to extract part of an URL with the low level
API.
Basically what I'd like to do is:
1. val requestHandler: HttpRequest => HttpResponse = {
2. case HttpRequest(GET, Uri.Path("/my_path/:parameter"), _, _, _) =>
3. HttpResponse(StatuCodes.OK)
4. }
and
Hi RIchard,
there's a PR fixing this and the larger issue which is JDK8 types exposure in
that API.
Will be merged any moment now: https://github.com/akka/akka/pull/19636 for
2.4.2.
--
Cheers,
Konrad 'ktoso’ Malawski
Akka @ Typesafe
On 15 February 2016 at 05:47:23, Richard Rodseth
13 matches
Mail list logo
