fs2

0熱

1答えて

ウェブサイトのロードジェネレータであるシステムをモデル化しようとしています。今のところ、ウェブサイトには文字列のページがあります。 type Page = String val pages: Vector[Page] = Stream.eval(Task.delay { new Random().alphanumeric.take(10).mkString }).repeat.ta

0熱

1答えて

http4sでのマルチパートコンテンツの処理

http4sライブラリを使用してマルチパートコンテンツを処理するにはどうすればいいですか？は（完全な要旨はhereである）次のスニペットを使用してサービスを想像してみて： case GET -> Root/"form" => Ok( """|<html> |<body> |<form method="post" action="/post" enctyp

2熱

1答えて

fs2：Seqの成功を確認する（仕事）

私はいくつかの要求を実行した後、結果の集まりを得る非同期http4sクライアントを持っています。このコレクション（Seq[Task[Response]]）がすべてのTaskオブジェクトに対して終了し、Responseオブジェクトが特定の状態にあることを確認したいと思います。私が代わりにタスクのFutureを使用していた場合、私の代わりにfs2.Taskを使用して、同様の機能を実現する方法はあり

0熱

1答えて

`ストリーム`を命令的な読み取り操作に変換する方法

私はStream[F,A]を持っています。fs2を認識していないコードベースの部分で消費されるためには、次の "プリミティブストリーミングインタフェース" trait PrimitiveStreamRepr[F[_]] { def read: F[Option[A]] def close: F[Unit] } どうすればいいですか？多分答えはそのような変換は不可能で、一

2熱

1答えて

FS2を使用してScalaで再帰的なフィボナッチシーケンスを実装する方法は？

はFS2に精通しようと、私はScalaのコレクションストリームを使用してnifty recursive implementationに出くわした、と私はFS2でそれをしようで行くを持っているだろうと思っている間： import fs2.{Pure, Stream} val fibs: Stream[Pure, Int] = Stream[Pure, Int](0) ++ fibs.fol

0熱

1答えて

http4s＆fs2でREST APIクローラーを並列化する方法は？

は、私がここにhttp4s & FS2にシーケンシャルRESTのAPIクローラを書いた： https://gist.github.com/NicolasRouquette/656ed7a2d6984ce0995fd78a3aec2566 これは、IDの開始セットを取得するためのREST APIサービスを照会IDのバッチのための要素を取得し、ベース続けることですこれらの要素で見つかった相互参照IDに