scalaz-stream

1зной

1ответ

scalaz потока TCP `echo` приложение не работает

я пишу эхо-приложение, которое send и receive'\0' завершённая строка https://gist.github.com/jilen/10a664cd588af10b7d09 object Foo { implicit val S = scalaz.concurrent.Strategy.DefaultStrategy

1зной

1ответ

Что такое хороший способ для реализации «замедленное» список потока в Scalaz

Я попытался сделать это, но это не сработало: Process("Hello", "Salut", "Bye", "Ciao").interleave(time.sleep(0.5.seconds).repeat)

4зной

3ответ

Как подключить сказазовые потоки к реактивным потокам (как в reactive-streams.org)

Я хотел бы передать данные, возвращенные из slick 3.0.0 запроса через db.stream (yourquery) через поток scalaz. Похоже, что reactive-streams.org используется модель API и потока данных, реализуемая ра

6зной

1ответ

scalaz-stream: как обрабатывать «заголовок» (первые куски) по-другому?

Контекст: Я пытаюсь написать Process1[ByteVector, spray.http.HttpResponsePart] с выходом ChunkedResponseStart(bytes), MessageChunk(bytes), MessageChunk(bytes), ..., ChunkedResponseEnd. Я еще не полнос

1зной

1ответ

В сказочном потоке, как я могу запустить задачу, когда раковина прекращена?

Я скопировал пример из http4s: // Print received Text frames, and, on completion, notify the console val sink: Sink[Task, WebSocketFrame] = Process.constant { case Text(t) => Task.delay(prin

2зной

2ответ

Как я могу выполнить логический вход в io.stdOutLines и ответить клиенту сервером scalaz.stream.tcp

Я очень новичок как в сказ-потоке, так и в scalas.stream.tcp. Я пытаюсь сделать очень простой сервер для своих образовательных целей. Я разбираю запросы в командах, выполняю их для создания ответов и