akka

5calore

3risposta

Ho una lista di file. Voglio: Per leggere da tutti come un'unica fonte. I file devono essere letti in sequenza, in ordine. (no round-robin) Non è necessario che nessun file sia interamente memorizzato

12calore

1risposta

Akka Streams. Stato di stato in un flusso

Voglio leggere più file di grandi dimensioni utilizzando gli stream di akka per elaborare ogni riga. Immagina che ogni chiave sia costituita da un ("identificatore" -> "valore"). Se viene trovato un n

7calore

1risposta

Akka Flow si blocca quando si effettuano richieste HTTP tramite il pool di connessioni

Sto usando Akka 2.4.4 e sto provando a passare da Apache HttpAsyncClient (senza successo). Di seguito è riportata una versione semplificata del codice che utilizzo nel mio progetto. Il problema è che

5calore

1risposta

Come posso utilizzare e restituire la coda di origine al chiamante senza materializzarlo?

Sto provando ad usare i nuovi stream di Akka e mi chiedo come posso usare e restituire la coda di Source al chiamante senza materializzarlo nel mio codice? Immaginate di avere una libreria che effettu

8calore

1risposta

Come assemblare un sink di Akka Streams da più scritture di file?

Sto provando ad integrare un flusso basato su stream akka nella mia app Play 2.5. L'idea è che puoi eseguire lo streaming in una foto, quindi scrivere su disco come file raw, una versione con miniatur

7calore

2risposta

Stream eventi query persistenza Akka e CQRS

Sto cercando di implementare il lato di lettura nella mia architettura ES-CQRS. Diciamo che ho un attore persistente come questo: object UserWrite { sealed trait UserEvent sealed trait Stat

5calore

1risposta

come posso contare Akka attuali connessioni aperte

sto cercando in Akka http "com.typesafe.akka" %% "akka-actor" % "2.4.6", "com.typesafe.akka" % "akka-http-experimental_2.11" % "2.4.6" sto testando il codice semplice, come di seguito. La mia d

13calore

1risposta

Caricamento file tramite Akka HTTP

Sto cercando di implementare la funzionalità di caricamento dei file nella mia applicazione usando Akka HTTP. Sto usando la versione akka-stream2.4.4. Ecco il codice (modificato da akka-doc) path("fil

16calore

1risposta

Perché Spark 1.6 non usa Akka?

Quando si legge il codice sorgente spark-1.6 della classe Master, il metodo receiveAndReply sembra non utilizzare Akka. [Cf. here.] Perché non usa Akka? E con che cosa hanno sostituito Akka?

5calore

1risposta

Stream di Akka - immissione di un flusso legato all'IO su un dispatcher diverso

Il mio stream ha un mix uniforme di CPU bound e livelli di IO bound (ogni fase IO è seguita da uno stage CPU). Quello che voglio fare è mettere le operazioni IO su un dispatcher diverso rispetto al re