akka-stream

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

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

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

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] =

7calore

2risposta

akka-http: richiesta completa con flusso

Si supponga di aver impostato un complesso arbitrariamente Flow[HttpRequest, HttpResponse, Unit]. posso utilizzano già detto flusso di gestire le richieste in arrivo con Http().bindAndHandle(flow, "0.

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

7calore

2risposta

Come vengono utilizzati i flussi reattivi in Slick per l'inserimento dei dati

Negli esempi Slick's documentation per l'utilizzo dei flussi reattivi vengono presentati solo per la lettura dei dati come mezzo di un DatabasePublisher. Ma cosa succede quando si desidera utilizzare

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