2回答
如何异步中断fs2流？
、、、
我正在尝试用SignalRef中断fs2流。我用下面的代码设置并运行了流。流应在switch包含false时运行，并应在switch包含true时中断 import cats.effect.IO import fs2.concurrent.SignallingRefswitch.map(_.get).unsafeRunSync))
program.compile.drain.unsafeRunAsync(() =>
浏览 30提问于2020-11-29得票数 2
2回答
假设我想将一些遗留的异步API转换为FS2流。API提供了一个带有3个回调的接口:下一个元素，成功，错误。我希望Stream发出所有元素，然后在接收到成功或错误回调后完成。FS2 guide ()建议在这样的情况下使用fs2.Queue，它对于排队非常有用，但是到目前为止，我看到的所有示例都期望queue.dequeue返回的流永远不会完成--在我的情况下，没有明显的方法来处理成功，但是如果成功/错误回调在客户端从流中读取数据之前到达，流就会过早终止--仍然有
浏览 0提问于2018-05-07得票数 4
回答已采纳
1回答
Linux信号是如何导致X86处理器的指令流中断的？那么使用的是什么CPU工具呢？同步中断是针对诸如页面错误、异常等问题。这些问题是由CPU上执行的指令引起的。异步中断来自来自LAPIC的IPI，定时器中断或I/O-APIC拾取的中断，并被路由到正确的LAPIC，然后中断处理器。所以这些都是外部事件。但是信号使用哪种X86机制来中断指令流<
浏览 1提问于2020-05-29得票数 0
1回答
我试图创建一个fs2流， persistToFile(jsonStream) <-- another fs2当中断发生时，该流是否有可能停止而不完成文件写入?如果是的话，是否可以确保该文件在退出发生之前被完全写入？
谢谢
浏览 3提问于2022-08-09得票数 1
在流教程中，没有提到关闭从Files.newInputStream( path )获得的流。只有一些模糊的：
返回的流是否异步关闭和/或可中断是高度特定的文件系统提供程序，因此没有指定。在这种情况下，什么是“异步”？如果我显式地关闭流，或者如果另一个线程异步关闭流？
浏览 8提问于2015-01-20得票数 6
回答已采纳
1回答
是否可以在fs2中创建离散事件流？如果是的话该怎么做。我刚开始和图书馆玩，我知道我有很多东西要学。但我没有看到任何与此相关的例子。例如，我希望在标尺或swing中为"mousemove“或"click”创建一个流。document.body.addEventListener("mousemove", event =>{ })fs2中的等价物可能并不是那么琐碎，但如果有人能建议我如何做。
浏览 3提问于2017-08-04得票数 3
3回答
正如您所看到的，与来自非流代码的流进行交互非常简单-- ActorRef特征上的!方法是异步的，不需要调用任何额外的机制。然后，发送给参与者的每个事件都会通过整个反应管道进行处理。然而，我找不到一种方法来正确地用FS2做同样的事情。即使不考虑缓冲(我可能需要编写一个自定义的Pipe实现来做我们需要的其他事情)和HTTP连接池的问题，我仍然被一个更基本的问题所困扰--那就是如何“从外部”将数据推送到反应流。fs2确实有某种fs2.concurrent.Queue，但同样，所有文档都展示了<
浏览 8提问于2018-11-30得票数 8
1回答
我有一些使用CompletableFuture运行异步的流，例如： .thenAccept(aaa -> {现在，我必须检查所有的null，在未来的每一个街区，但这是丑陋的。编辑
做A，当A完成时，做B，然后做C.我
浏览 0提问于2015-06-29得票数 5
回答已采纳
2回答
如何将阿克卡演员与衰落结合起来
、、、、
我有一个包含akka、akka http和akka streams的应用程序，所以它不是rest或微服务是一个短暂的应用程序；它是rest的数据提取器，应用程序写到postgres db，它的工作原理--我对以这种方式将衰落和akka集成起来是否正确感到怀疑。object App extends CommandIOApp(name = "app" , header = "extractor", version = "0.1.0") {
val config = Config( token, jdbcDriver = jdbcD
浏览 3提问于2021-02-24得票数 0
回答已采纳
1回答
:forestgreen;">${datetime} :: ERROR :: ${message}</span>`, 'text/html'); }是像这样吗？
浏览 1提问于2022-04-13得票数 0
回答已采纳
2回答
我有一个服务，它可以将线程拆分来侦听传入的tcp流。OnStart(string[] args) worker = new Thread(ListenForStatus);}{ //Do Something
}
浏览 14提问于2022-03-03得票数 0
1回答
如何在任务中更改值
、、、、
我想在不中断async函数流的情况下这样做。GetDataAsync(url); return data;在函数GetPageText中，如何在不中断异步流的情况下操作数据变量
浏览 3提问于2014-12-30得票数 1
回答已采纳
package:connect/Screens/Account/Community/Community.dart:119:21) E/颤振(15767)：#2 _RootZone.runUnary (飞镖:异步/zone.dart:1612:54)E/颤振(15767)：#3
_FutureListener.handleValue (dart:异步/未来_INST.DAT:152:18)E/颤振(15767)_propagateToListeners.handleVal
浏览 0提问于2021-03-17得票数 0
2回答
我想用FileStream编写SourceFileName，但是当我为此创建代码时，一条错误消息表示正在使用文件流。如何交替，所以我打开源文件，然后写下来，然后存储在同一个源文件中。SourceFileName, string output, string Key) try FileStream FS1 = null; FileStream FS2= null; <
浏览 4提问于2014-01-16得票数 0
回答已采纳
1回答
在goroutine中向远程服务器发出I/O请求(如GET请求)
我希望这看起来
浏览 2提问于2016-04-08得票数 2
回答已采纳
我搞不懂应该在哪里正确地放置异步-等待强制它完成块。另外，我能否问一下我在哪里可以读到关于颤振的正确执行流程的解释，以便我能更好地理解它？
浏览 1提问于2022-01-13得票数 0
回答已采纳
1回答
new GZIPInputStream(new BufferedInputStream(new FileInputStream(s))))fs2似乎有一个压缩对象()，它似乎应该执行所需的操作，但是如果它还没有解决如何集成的问题。因此，问题是:如何将压缩后的文件读入流中，以便在功能范例中使用fs2？
浏览 7提问于2022-08-31得票数 1
回答已采纳
我获得了一个通过异步调用NetworkStream.BeginRead (传递异步回调委托)读取的TCP客户端流。问题是要检测连接何时中断。如果应用程序在流中尝试发送，这会触发回调，NetworkStream.EndRead抛出一个异常--这是可以的--但是如果没有发送，那么应用程序就会陷入黑暗的状态，即连接中断。编辑: MSDN文档清楚地指出，ReadTimeout只适用于同步读取调用，而不适用于asyn BeginRead -我应该更早地检查它:-(
如何检测客户端
浏览 6提问于2011-05-13得票数 0
回答已采纳
我们如何将该信息作为呼叫的一部分，并在一周或一个月后以异步调用的形式获得？同步调用可能不会向我们显示正在处理的总数据，因为通道可能会中断，而bq可能会继续处理和充电使用，因此我们需要进行异步调用来填补空白。使用GetQueryResultsResponse类在循环中对数据进行流
浏览 5提问于2015-01-29得票数 3
回答已采纳
我想将Monix Observable与Doobie (fs2)流一起使用，但似乎无法正常工作。dbUrl, dbUser, dbPassword, ecBlocking, Blocker.liftExecutionContext(ecBlocking))
} 我已经根据Monix文档将fs2流转换为Monix observable：https://monix.io/docs/current/reactive/observable.html#fs2 我是否需要以某种方式关
浏览 20提问于2020-08-23得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
