scalaz-stream

6calore

1risposta

scalaz-stream: come gestire "intestazione" (primi blocchi) in un modo diverso rispetto agli altri?

Contesto: Sto cercando di scrivere un Process1[ByteVector, spray.http.HttpResponsePart] con l'output ChunkedResponseStart(bytes), MessageChunk(bytes), MessageChunk(bytes), ..., ChunkedResponseEnd. Non

6calore

1risposta

Come migliorare le prestazioni del codice con Sink?

Ho una strana osservazione sui sink dei flussi di scalaz. Stanno lavorando lentamente. Qualcuno sa perché è così? E c'è un modo per migliorare le prestazioni? qui sono parti rilevanti del mio codice:

11calore

1risposta

Perché abbiamo bisogno di scalaz.stream su iteratee?

Recentemente, ho giocato con scalaz.iteratee e Play iteratee. Penso che iteratee sia una buona idea fornire la modularità invece del vecchio ciclo imperativo mentre lo scopo è usare una funzione come

6calore

2risposta

Arrestare un processo [task, O] all'input dell'utente

sto cercando di scrivere la seguente funzione def haltOnUserInput[O](process: Process[Task, O]): Process[Task, O] che arresta process quando l'utente invia una linea su stdin. In questo scenario, è

10calore

1risposta

Come leggere da TCP e scrivere su stdout?

Non riesco a ottenere un semplice esempio di scalaz in esecuzione, la lettura da TCP e la scrittura su std out. val src = tcp.reads(1024) val addr = new InetSocketAddress(12345) val p = tcp.server(a

9calore

1risposta

Scala file di testo veloce lettura e caricare in memoria

In Scala, per la lettura di un file di testo e caricarlo in un array, un approccio comune è scala.io.Source.fromFile("file.txt").getLines.toArray Soprattutto per file molto grandi, c'è un approccio

5calore

1risposta

Qual è lo scalaz-stream equivalente a giocare Enumerator.fromCallback del quadro

biblioteca iteratee Play Framework definisce un metodo Enumerator.fromCallback che permette gli elementi per essere generati sulla base dei risultati di un futuro: http://www.playframework.com/documen

7calore

1risposta

Come convertire Iterator in flusso scalaz?

Supponiamo di avere un Iterator[A]. Vorrei convertirlo in Process[Nothing, A] di scalaz stream. import scalaz.stream._ def foo[A](it: Iterator[A]): Process[Nothing, A] = ??? Come implementare foo?