scalaz-stream

5열

1답변

`구현 물어 - 다음 - 대기 - reply` TCP 클라이언트

을 내가 HTTP (유사) 한 후 그 응답을 기다리는 첫 번째 서버로 요청을 보낼 클라이언트 응용 프로그램을 구현하기 위해 내 클라이언트를 원하는 방법을 scalaz - 스트리밍 과정은 여기 val topic = async.topic[ByteVector] val client = topic.subscribe 이 trait Client { val

scala scalaz scalaz-stream 2015-01-15

---

6열

1답변

싱크대의 코드 성능을 향상시키는 방법은 무엇입니까?

나는 scalaz-streams sink에 관한 이상한 관찰을 가지고있다. 그들은 천천히 일하고 있습니다. 아무도 왜 그런지 압니까? 그리고 성능을 향상시킬 수있는 방법이 있습니까? 7S이 하나가 실행 33 개의 초 정도 걸립니다 //p is the same as before def printToImage(img: BufferedImage)(pixel:

scalaz-stream 2014-10-14

---

1열

1답변

스 카즈 - 스트림이있는 모나드 변압기

이 스 니펫 y.run에는 typecheck가 없습니다. could not find implicit value for parameter C: scalaz.Catchable[[x]Test.StateStringTask[x]] 내가 StateStringTask에 대한 Catchable 인스턴스를 생성해야합니까 : object Test { type St

scala monad-transformers scalaz-stream 2016-07-30

---

1열

1답변

scalaz stream io에서 append 메소드를 사용하면 무한 루프가 발생합니다.

scalaz stream 웹 사이트에서이 코드를 사용합니다. 메소드와 함께 작동하지만 추가를 사용하려고하면 오류가 발생하여 무한 루프처럼 보이고 끝나지 않습니다. append 메서드를 사용하려는 이유는 메서드에 사용하여 파일을 다시 작성하지 않아야하기 때문입니다. io.linesR(t) .intersperse("\n") .pipe(text

scala scalaz7 scalaz-stream 2014-10-23

---

0열

1답변

신비 스칼라 NoClassDefFoundError 및 scalaz.InvariantFunctor 오류

다음 build.sbt가 있으며 IntelliJ에서 sbt를 관리하는 스칼라 2.10.4를 실행하고 sbt 빌드 파일을 기반으로 프로젝트를 새로 고칩니다. 이이 build.sbt와 // build.sbt name := "ScalazStreamsAkka" version := "1.0" resolvers += "Scalaz Bintray Repo"

scala intellij-idea akka scalaz scalaz-stream 2014-09-09

---

6열

1답변

scalaz-streams의 태스크에서 예외 로깅 및 무시

일부 스카치 스트림 문서의 예제를 살펴 보겠습니다. import scalaz.stream._ import scalaz.concurrent.Task val converter: Task[Unit] = io.linesR("testdata/fahrenheit.txt") .filter(s => !s.trim.isEmpty && !s.start

scala scalaz7 scalaz-stream 2014-12-18

---

1열

1답변

scalaz 스트림 TCP는

나는 send과 receive'\0' 문자열 내가 다른 터미널 을 그리고에 Foo.runServer() 및 Foo.runClient()을 실행 https://gist.github.com/jilen/10a664cd588af10b7d09 object Foo { implicit val S = scalaz.concurrent.Strategy.Defaul

scala scalaz scalaz-stream 2015-02-07

---

1열

1답변

왜 Process0이가 <strong>Process0</strong> 정의하는 방법이다 프로세스 [ID, O]

sealed trait Process[+F[_], +O] /** * Created by pach on 11/07/14. */ package object stream { type Process0[+O] = Process[Nothing,O] ... } 으로 정의되어 있지 않습니다. Nothing이 형식 매개 변수를 사용하지 않기 때문에

scala scalaz scalaz-stream 2014-09-13

---

4열

1답변

scalaz-stream에 두 가지 네트워크 io 구현이있는 이유는 무엇입니까?

이들은 scalaz.stream.tcp 및 scalaz.stream.nio에 있습니다. tcp 버전은 Connection Process[Task, A] 같은 nio 버전은 왜이 두 가지 버전이 존재 ConnectionProcess[Task, Exchange[I, W]]으로 취급 취급? 어떤 상황을 의도합니까?

scala scalaz scalaz-stream 2014-11-02

---

1열

1답변

ScalaZ Process를 중단하는 방법 time.awakeEvery?

내가 배운 점은 scalaz.stream.time.awakeEvery(1.second) 1 초마다 이벤트를 만드는 프로세스를 만들 수 있습니다. 아주 명백하다. 그런 다음 매 초마다 일부 작업을 수행하기 위해 해당 프로세스를 매핑 할 수 있습니다. 여태까지는 그런대로 잘됐다. 이 활동을 중단하려면 어떻게해야합니까? 나는 p.kill.run.run을 시도했는

scalaz-stream 2016-11-25

---