fs2.Stream[IO，Something]在take(1)时不返回
fs2.Stream[IO, Something]在take(1)时不返回的原因可能是因为Stream中的元素还没有准备好或者还没有到达。在使用fs2库时，Stream是一个惰性的数据结构，它允许异步处理数据流。当调用take(1)时，它只会返回一个Stream，而不会立即执行计算。
要确保Stream中的元素准备好并且可以被取出，可以使用一些操作符来控制Stream的行为。例如，可以使用evalTap操作符在每个元素被取出之前执行一些副作用操作，以确保元素已经准备好。另外，可以使用pull操作符来手动控制Stream的推送，以确保元素已经到达。
在处理Stream时，还可以使用其他操作符来处理错误情况。例如，可以使用handleError操作符来处理可能发生的异常，或者使用recover操作符来处理错误并返回一个默认值。
关于fs2库的更多信息和使用示例，可以参考腾讯云的fs2.Stream[IO, Something]相关产品和产品介绍链接地址（这里给出一个示例链接，具体根据实际情况选择合适的链接）：https://cloud.tencent.com/product/fs2
相关·内容
我有一个函数，它返回一个fs2测量值流。] = blocker <- Stream.resource(Blocker[IO]) .through(SdsStateMachine.collectMeasurements())
} yield stream 通常，它是一个无限流，除非我向它传递一个测试标志val inf
浏览 15提问于2019-12-13得票数 3
1回答
Fs2.流坚持两次
、、、、
尝试：我尝试使用fs2.Stream::take并运行了一些示例。.covaryAll[IO, Int].evalTap(queue.enqueue1).compile.drain _ <- stream.take(
浏览 2提问于2021-08-17得票数 0
回答已采纳
我正在使用fs2.Stream进行实验，并且在类型推断方面遇到了一些误解。假设我们有以下代码：val s: fs2.Stream[IO, Int] = fs2.Stream.eval但我不明白为什么这种类型是fs2.Stream[IO, Int]？def emits[F[x] >: Pure[x], O](os: Seq[O]
浏览 0提问于2018-08-25得票数 0
回答已采纳
我可以编写类似于以下内容的内容，并且它的工作方式与它应该做的一样(它产生10)：import cats.effect.unsafe.implicits.globalval zz: fs2.Stream[IO, Int] = fs2.Stream.iterate[IO, Int](1)(_+1).map(_*2)
val qq: IO[Int] = zz.dropWhile(_ < 10).take(<
浏览 9提问于2022-11-12得票数 0
回答已采纳
1回答
我在单元测试(使用mockito)中模拟MVar2方法make时遇到了困难。我试过这个：当我试图模仿这个方法时，就像： "testString".pure[IO], ) def run: F[U
浏览 3提问于2021-12-13得票数 0
回答已采纳
1回答
我需要一个组合器来解决以下问题： val s = Stream(1, 2, 3, 4, 1, 2, 3, 3, 1, 2, 2).covary[IO]val grouped: Stream[IO, Stream[IO, Int]] = s.groupUntil(_ == 1)
for {
group注意:当内部流到达原始流时，我必须立即
浏览 6提问于2021-06-16得票数 0
回答已采纳
// when we reach "Count" then exit out of the foreach loop}
我这样叫它：Class.GetList(10);，它将返回我想通过使用Class.GetList().Take(10)来使用IEnumerable的Take()方法，我希望foreach循环能够以某种方式获取我传递给Take()的数字-这可能吗?
浏览 0提问于2010-11-14得票数 4
回答已采纳
1回答
为了进行测试，我做了以下工作：[filename] (doall(line-seq rdr))))
如果我只是在repl中计算(take1 (read-file filename))，我将得到文
浏览 3提问于2013-10-10得票数 0
回答已采纳
我在“网络”线程中等待来自'io‘线程的信号有问题。主”线程中，我有两个排队事件(do_something1和do_something2在‘网络’线程中执行)：在do_something1方法中，我有以下代码：QObject::co
浏览 1提问于2018-05-05得票数 0
回答已采纳
3回答
使用继承方法定义方法
、、、、
我试图通过使用堆栈的继承的push方法来定义void方法，但是add(T thing)表示返回类型与Vector<T>.add(T)不兼容，并希望我将add(T)的返回类型更改为布尔值，这是没有意义的。下面是我的代码 Stack<T> stack1=new Stack<T>();
public ListStack(
浏览 3提问于2013-10-30得票数 1
回答已采纳
2回答
FS2流异常处理不起作用
、、、
我在FS2和异常处理方面遇到了问题。我想要的是，给定一个Stream[IO,A]，当我使用一个可以抛出异常的f: A => B在它上面进行映射时，我会获得一个Stream[IO,Either[Throwable,B]]。我尝试了以下方法，它的效果与预期一致：val x1 = fs2.Stream.emits(Vector(1,2,3,4)).covary[IO]
.map: I
浏览 36提问于2018-02-12得票数 3
回答已采纳
我正在尝试遵循这里给出的例子:在for...yield循环内执行非阻塞IO的。 state(socket)(IO.Chunk(bytes)) state(socket)(IO.EOFtake 1 println("
浏览 0提问于2012-04-04得票数 2
回答已采纳
1回答
并发流不会打印任何控制台
、、、
我正在尝试构建一个关于在Stream.concurrently中使用fs2方法的示例。我正在开发生产者/消费者模式，使用Queue作为共享状态： val queue: IO[Queue[IO, Int]] = Queue.bounded[IO, Int](10)
r <- random p
浏览 5提问于2022-01-23得票数 0
回答已采纳
3回答
假设代码f = f >>= return . (0 :)
g = f >>= return . take 3f' :: [Int]g' = take 3 f'
编辑：--事实上，我对拥有这样一个简单的函数f并不感兴趣，原始代码看起来
浏览 3提问于2015-09-09得票数 3
回答已采纳
例如，我想做这样的事情： c <- getChar then putStrLn "take action 1"else putStrLn "take action 2"
但是，不能直接将char文字与IO进行比较。无法将预期类型‘IO Char’与实际类型‘Char’.在‘(==)’的第二个参数中匹配，即'q‘在<
浏览 0提问于2019-03-10得票数 3
回答已采纳
我一直在玩Simple.Data，遇到了一些我无法理解的东西。var db = Database.Open(); }} 'Simple.Data.SimpleRecord‘不包含“项目”的定义
但是，下列代码确
浏览 0提问于2012-02-01得票数 0
回答已采纳
1回答
我想用RxJava在WebView中实现单击删除。首先，我认为throttleFirst对此很有好处。throttled.subscribe(new Action1<String>() { public void call(String url) {
// i want to throttle events and return <e
浏览 4提问于2015-02-17得票数 1
在二进制文件中存储树结构时，通常会存储一个块序列，每个块包含：[type_id, size, ... ]和可选嵌套的子块。见：。在为这类数据编写读取器时，重要的是确保递归的每个级别都准确地读取由其块大小定义的字节数。
即使使用Seek特性(虽然它允许跳过下一个块)，它也不能确保嵌套函数不会超出它们的范围。是否有一种方法可以使用将文件的一部分大小调整到块大小，然后在递归函数中从其中读取？是否可以在函数中使用Read::<e
浏览 4提问于2017-02-17得票数 1
我的目标是在映射集合中添加值，直到其中一个映射值达到值为止。我试着用来解决这个问题，但是它并没有触及到我如何才能抓住列表的一部分。然后返回集合，而不返回遍历的值。就像这样(defn addValuesUp [foo]
(take-while (< ((apply merge-with + foo
浏览 2提问于2016-02-01得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
