akka

5calore

1risposta

Come limitare un flusso Akka per eseguire e inviare un messaggio solo una volta al secondo?

Possiedo un flusso Akka e voglio che lo streaming invii messaggi in streaming all'incirca ogni secondo. Ho provato due modi per risolvere questo problema, il primo modo era far sì che il produttore al

5calore

2risposta

Pool di lavoratori con Akka Streams

Come descritto in akka streams documentation ho cercato di creare una riserva di lavoratori (flussi): def balancer[In, Out](worker: Flow[In, Out, NotUsed], workerCount: Int): Flow[In, Out, NotUsed] =

9calore

1risposta

ClassCastException: interfaccia akka.actor.Scheduler non è assegnabile dalla classe akka.actor.LightArrayRevolverScheduler

Sto cercando di eseguire qualcosa che ho eseguito con successo in una varietà di condizioni per mesi. Sto usando akka-actor_2.11 2.3.4 con scala-library 2.11.7 da un'applicazione Java con Java 7. Come

19calore

2risposta

Come convertire Akka ByteString in String?

Mi dispiace se questa è una domanda stupida, ma onestamente non riesco a capirlo senza impostare una sorta di codice ASCII -> mappatore di caratteri me stesso, che non penso sia il modo giusto per far

13calore

1risposta

Come utilizzare un flusso Akka SourceQueue con PlayFramework

Vorrei utilizzare un SourceQueue per spostare gli elementi dinamicamente in una sorgente di Akka Stream. Il controller di riproduzione necessita di una sorgente per poter trasmettere un risultato util

10calore

2risposta

Attendere la chiamata futura asincrona prima dell'elaborazione del messaggio successivo in Akka

Durante la ricezione di eventi, Akka Actors elaborerà un messaggio alla volta, bloccando finché una richiesta non è stata completata prima di passare al messaggio successivo. Questo funziona bene per

5calore

2risposta

Lavello per file linea per riga IO con contropressione

Ho un processo di elaborazione file che attualmente utilizza gli attori di akka con la contropressione gestita manualmente per gestire la pipeline di elaborazione, ma non sono mai stato in grado di ge

5calore

1risposta

Flussi alternativi basati su condizioni per stream akka

Avere uno stream con flussi personalizzati e ad un certo punto voglio dividere il flusso e disporre di due alternative di gestione dei dati che si uniranno di nuovo in seguito. E.g. -> F3 -> F6 S

5calore

1risposta

Come inviare un messaggio in un flusso reattivo da un sottoscrittore a un editore in una connessione socket Web

La mia applicazione ha un'interfaccia Akka-Websocket. La presa web è composta da un attore-sottoscrittore e un editore attore. L'utente gestisce i comandi, inviandoli all'attore corrispondente. L'edit

7calore

2risposta

Differenza tra i servizi remoti trasparente e trasparenza posizione

Googled un po 'per trovare una buona spiegazione della differenza tra queste due strategie di comunicazione remota, vale a dire i servizi remoti trasparente e posizione di trasparenza. Per quanto ne s