16 questions
1
vote
0
answers
74
views
Why is mapAsync internal buffer not getting garbage collected?
I've written following snipped to mimic my problem:
implicit val actorSystem: ActorSystem = ActorSystem()
implicit val executionContext: ExecutionContext = actorSystem.dispatcher
...
- 5,678
0
votes
0
answers
51
views
Issue getting akka or pekko TestKit EventFilter to work as expected
I have a simple 'classic' actor that just recieves a message and logs string Bingo to INFO. In my test I setup an InfoFilter EventFilter to verify the log.info message call. Debugging I can see that ...
- 103
0
votes
1
answer
64
views
Is there a way to create a RSocket "forRequestStream" and return it as a Pekko/Akka Sink without using the deprecated FluxProcessor?
In my use case, I need to use the RSocket protocol to create a reactive stream over the network, and on the client side return a pekko Source, and on the server side return a pekko Sink. I have no ...
0
votes
0
answers
63
views
Added directive for wrapping route
I have added a directive
object CustomDirectives extends Directives {
def wrapWithTracing(name: String)(innerRoute: => Route)(implicit req: RequestContext): Route = {
//start span
// ...
- 37
0
votes
1
answer
190
views
Akka to Pekko Migration and Grpc
Heeey all,
I'm doing a Akka to Pekko migration of a pet project (I'm learning scala atm). So far everything went smooth but there is one thing that I can't get fixed and the grpc plugin.
In my build....
- 372
0
votes
1
answer
122
views
Is there any way to access a RequestContext in a play framework endpoint?
Is there any function or a way to work around the RequestContext in PlayFramework, that works similarly to Pekko's extractRequestContext?
I'm migrating an old Akka rest API to Play3.0, and I need to ...
- 5
0
votes
0
answers
531
views
Flink Actor not found for: ActorSelection[Anchor(pekko://flink/deadLetters), Path(/)]
On my kubernetes cluster I have flink-kubernetes-operator 1.7.0 and apache-flink 1.18.1 installed. I came across an issue when I installed FlinkDeployment CR (custom resrouce) into a namespace named ...
0
votes
1
answer
211
views
Optimizing CPU Utilization and Throughput in Akka / Pekko Streams on HTTP
Consider the following code:
def getFlow()(implicit appConfig: AppConfig, actorSystem: ActorSystem): Flow[BrandSafetyServiceRequest, HttpResponse, NotUsed] = {
implicit val ...
- 1,152