scalaz-stream

    2热度

    1回答

    如何在进程中断时终止控制台输入

    我正在玩Scalaz Stream库并试图创建一个简单的控制台应用程序。 我按照教程scalaz streams，他们有一个控制台读写的例子。 但是我面临一个奇怪的问题，我不知道如何理清。 这是我的代码： import scala.concurrent.duration._ import scalaz.concurrent.Task object StreamApp extends App
    scala functional-programming scalaz scalaz-stream 2015-06-05

    2热度

    1回答

    如何合并相邻的线与scalaz流不失分割线

    假设我输入文件myInput.txt如下所示： ~~~ text1 bla bla some more text ~~~ text2 lorem ipsum ~~~ othertext the wikipedia entry is not up to date 也就是说，有通过~~~分开的文件。期望的输出如下： text1: bla bla some more text te
    scala scalaz-stream 2015-05-05

    0热度

    1回答

    如何设置NServiceBus和Log4Net保存到文件（不包含配置文件）

    我正在运行NServiceBus并拥有此issue。要尝试解决它，我想使NServiceBus日志文件。 问题是我在IIS中托管NServiceBus，而不是NServiceBus.Host.exe。因此，我不知道打开生产配置文件的方法。 有没有办法告诉NServiceBus登录到不使用配置文件的文件？ （或者在不使用NServiceBus.Host.exe时设置配置文件的方法？） 我曾希望有一种
    log4net nservicebus 2012-03-20

    0热度

    1回答

    从队列中scalaz

    我想跟随在一些差距https://github.com/functional-streams-for-scala/fs2/wiki/Binding-to-asynchronous-processes 灌装的第一个例子创建过程，并增加了一些调试打印我到了下面的代码： import java.util.concurrent.ScheduledExecutorService import scala.
    scala scalaz scalaz-stream 2017-02-12

    1热度

    1回答

    单面变压器与scalaz流

    在这个片段y.run不typecheck。 object Test { type StateStringTask[A] = StateStringT[Task, A] type StateStringT[M[_], A] = StateT[M, String, A] val x: Process[Task, Unit] = ??? val y: Pro
    scala monad-transformers scalaz-stream 2016-07-30

    0热度

    1回答

    如何将Scalaz-Stream Process [F，Option [T]]转换为Process [F，T]？

    我有一个scalaz流过程： val src = Process.repeatEval(Task(in.take())) : Process[Task, Option[T]] 如何摆脱期权？ 到目前为止，我已经使用收集，但给人的感觉并不优雅： src.collect { case Some(x) => x } : Process[Task, T] 有没有更好的办法？
    scalaz-stream 2016-03-06

    0热度

    1回答

    scalaz-stream基于计算值消耗流量

    我有两个流，我希望能够根据每运行x秒的计算来使用一个流。 我想我基本上需要创建第三tick流 - 类似every(3.seconds) - ，做计算，然后拿出某种其他两个之间的切换。 我有点卡在这里（我只是刚刚开始与scalaz-stream混在一起）。 谢谢！
    scala scalaz-stream 2016-03-11

    1热度

    2回答

    Scalaz流分块多达N

    给定一个队列像这样： val queue: Queue[Int] = async.boundedQueue[Int](1000) 欲拉断该队列和它传输到下游水槽，在UP的组块100。 queue.dequeue.chunk(100).to(downstreamConsumer) 作品之类的，但如果我有说101个的消息就不会清空队列。剩下1条消息，除非另有99个消息被推入。我希望尽可能多地从
    scala scalaz scalaz-stream 2015-08-28

    2热度

    2回答

    http4s - get请求体String或InputStream的

    我试图定义HttpService接收JSON并将其与json4s库解析到案例类： import org.http4s._ import org.http4s.dsl._ import org.json4s._ import org.json4s.native.JsonMethods._ case class Request(firstName: String, secondName: S
    scala scalaz-stream http4s 2016-05-04

    1热度

    1回答

    如何停止由time.awakeEvery创建的ScalaZ进程？

    我通过scalaz.stream.time.awakeEvery(1.second)了解到，我可以创建一个每秒创建一个事件的进程。非常明显。然后，我可以将该流程映射为每秒完成一些任务。到现在为止还挺好。 如果我想停止此活动，该怎么办？我试过p.kill.run.run，其中p是由time.awakeEvery(1.second)创建的过程，但它不起作用。 因此，代码如下所示： implicit v
    scalaz-stream 2016-11-25
最新问题