Hi,
In my code, I am creating a pool in the following standard manner:
private lazy val scriptProcessor: ActorRef =
context.actorOf(BalancingPool(poolSize).props(ScriptProcessor.props()),
scriptProcessor)
If I use RoundRobinPool or SmallestMailboxPool, my code works fine.
However, for
Hi Avi,
The authoritative answer should come from the library that gave you the ===
operator, but if my guess is correct that this is ScalaTest then what you are
seeing is easily explained by the fact that === is just a more type-safe
version of ==, meaning that it returns a boolean. If you
Hi, all
I'm doing some development based on cluster sharding,
everything works if I declare the dependency in build.sbt
However,
when I:
step 1. remove the dependency in built.sbt
step 2. checkout release-2.3 in akka's source directory
step 3. sbt assembly to get
I'm a newbie with Akka Streams so please excuse me if the question seems
stupid. I have the need to pass some context info along with the events in
a stream. For example, I have something like the following (doesn't
compile - just for illustration):
case class RequestFile(
req:
Hello,
I’m struggling to understand how I can complete an akka-http RequestContext
asynchronously, using a future. Synchronously completion is
straightforward, e.g…...
val bundleRoutes = {
(pathPrefix(bundles) get) {
path(Segment / meta) {
bundleId = complete {
Hello,
I’m struggling to understand how I can complete an akka-http RequestContext
asynchronously, using a future. Synchronously completion is straightforward,
e.g…...
val bundleRoutes = {
(pathPrefix(bundles) get) {
path(Segment / meta) {
bundleId = complete {
I also tried the following two ways, still doesn't work
1. publish to local maven repository and add dependency in build.sbt
2. reset the code to the last commit of 2.3.8, compile,
On Wednesday, March 11, 2015 at 4:34:35 PM UTC-4, Nan Zhu wrote:
Hi, all
I'm doing some development based
Hi,
Completing a route with a Tuple3[StatusCode, Seq[HttpHeader], T] doesn't
seem to work for me. My json4s marshaller serializes the whole tuple as an
object. Tuple2[StatusCode, T] works instead.
Are there any plans to implement it?
What's the best way to add headers to a response anyway? In
This is what I came up with (I have another question below):
def onSuccessHead(magnet: OnStreamSuccessHeadMagnet): Directive[magnet.Out] = {
magnet.directive
}
trait OnStreamSuccessHeadMagnet {
type Out
def directive: Directive[Out]
}
object OnStreamSuccessHeadMagnet {
import
Patrik, is it any fundamental problems in API right now? Do you plan to
break backward compatibility before 1.0?
вторник, 10 марта 2015 г., 16:18:35 UTC+6 пользователь Patrik Nordwall
написал:
We will release 1.0 as soon as possible, but not earlier. We will continue
to release frequent
Hello everybody,
I just posted a problem I am struggling with on stackoverflow
http://stackoverflow.com/questions/28982333/akka-camel-websocket-client-producer.
I haven't got too many views there and no answer so far, so decided to post
it over here to people who use Akka the most; maybe
Hi James,
I'm on my phone right now but I think you'll need an implicit execution context
in scope. That error message should definitely be improved if possible.
Regards,
Roland
Sent from my iPhone
On 11 Mar 2015, at 14:24, James Mulcahy ja...@manque.net wrote:
Hello,
I’m
Hi Vladimir
I have had good luck with using per-request actors as in the Net-a-porter
activator template, and a replyTo:ActorRef in the messages sent to my
DbActor (which still talks to a DAO)
Some more detail in this thread
13 matches
Mail list logo
