回答情况：
提问时间：
问题标签：
因此，在某种方法中，我将打开一个新的IO流，对它进行一些处理，然后使用该流作为输入来打开另一个IO流。我不相信我可以使用一个尝试资源块，因为第一个IO流在打开第一个流和第二个流之间。我知道，如果在第一个和第二个IO流之间没有处理，最好在一个带有资源的尝试块中打开所有三个流。= null; SomeIOS
浏览 1修改于2015-09-29得票数 2
回答已采纳
我有一个由一些元素(可能是无限的)组成的fs2.Stream，我希望同时为流的所有元素安排一些计算。这是我试过的implicit val timer: Timer[IO] = IO.timer(ExecutionContext.global)
id <- fs2</em
浏览 0提问于2020-07-14得票数 2
回答已采纳
2回答
我正在尝试用SignalRef中断fs2流。我用下面的代码设置并运行了流。流应在switch包含false时运行，并应在switch包含true时中断 import cats.effect.IO import fs2.concurrent.SignallingRef(ExecutionContext.global)
implicit val timer = IO.timer(ExecutionCont
浏览 30修改于2020-11-30得票数 2
我在googled上搜索了一些关于如何优化不同IO流的内容，但并没有真正理解以下内容：
new System.IO.StreamWriter(@"C:\Calculations\data2.txt", true))
关闭和冲洗溪流
浏览 1提问于2018-06-22得票数 2
回答已采纳
我想从队列中创建流，它将把所有元素打印到控制台中。(ExecutionContext.global)
queue <- Queue.noneTerminated[IO, String] val stream: fs2</e
浏览 25修改于2021-03-29得票数 1
这是我如何写入一个流，然后使用一个线程从它读取： ms.Write(new byte[] { 1, 2, 3, 4, 5, 6, 7 }, 0, 7);
// go to the beginingms.Seek(0, System.IO.SeekOrigi
浏览 2提问于2012-09-08得票数 19
回答已采纳
1回答
每个控制器连接到多个数据端口，每个端口都有一个输入和输出流。我通过给每个端口一个BinaryReader和BinaryWriter来建模这种关系，每个端口都有自己的MemoryStream支持。因此，我的问题是:如何使用两个不同的BinaryReader/BinaryWriter或MemoryStream集来伪造这样的IO流，这样，当我向其中一个写入时，另一个可以立即读取它？
浏览 1修改于2014-08-12得票数 2
回答已采纳
我想使用 Streams，cats 和 IO定义一个具有以下签名的函数。def list2Stream[A,B,F[_],S](vs: List[A], ): EitherT[IO,S,Stream[IO,B]] = {它会将来自vs的每个值映射到一个值流，并将
浏览 2提问于2019-12-11得票数 0
Output的签名是IO[List[A]]fs2.Stream.eval(input).flatMap(x => fs2.Stream.apply(x))谢谢
浏览 0修改于2018-04-10得票数 5
回答已采纳
我在客户端(dart)和服务器(.net)之间有双向流。当客户端有大的流调用循环时，我遇到了问题。: The HTTP/2 connection faulted. at System.IO.Pipelines.PipeCompletion.ThrowLatchedException()
at System.IO.Pipelines.Pipe.GetReadResult(ReadResult&
浏览 15提问于2021-01-23得票数 1
回答已采纳
我正在用Rust编写代码来解析数据流，trait Stream。流可以由其他流组成。特征StreamIterator提供对子流的访问。这是在解析tar文件、zip文件和其他包含文件的文件时使用的。在main中，文件以流的形式打开。该流被传递给analyze函数，该函数尝试将流作为TarStreamIterator打开，以迭代tar中的流。还分析了每个嵌入的流。Stream<T> for FileStream {
f
浏览 1提问于2016-05-06得票数 2
当一个不可重试的错误发生时，按照此，写流将保持较长的生存期并刷新它。如果数据是流动的，一切都很好。没有错误。但是，我想测试刷新流写入器的工作，所以我等待默认的流超时(10分钟)，这将关闭流，然后再次尝试写入。我可以很好地创建流，那里没有错误，但是对于其中一个表，我一直被取消的错误包装在一个预条件中失败，使我的代码一次又一次地刷新。!:
浏览 19提问于2021-08-02得票数 0
回答已采纳
我想在一个流中使用两个流指针，并将这两个指针放在不同的位置。如何制作第一个流的副本，以便该副本不会从该时间点镜像第一个流的状态？ 特别是，我对io.BytesIO()类型的流感兴趣。import io
print('A', stream1.tell(), stream2.tell())
浏览 26修改于2019-05-23得票数 0
._
val in1 = io.linesR("C:/tmp/as.txt") p.run.run文件as.txt包含五个as，文件bs.txt包含3个bs。abaaa
浏览 2修改于2014-11-18得票数 7
回答已采纳
出于教育目的，我正在尝试替换标准流stdout、stdin和stderr。我首先查找流的数据类型，并使用以下成员(gdb ptype _IO_FILE )将其追溯到结构_IO_FILE： int _flags;__pad2 = stdout->__pad2 };_IO_FILE *f3 = malloc(s
浏览 3修改于2014-01-31得票数 3
3回答
import io
string_out.write("hello")print(string_out.getvalue())OutPut2: hellonew Hello
我怎样才能从流中刷新第一个输入，这样第二个流的输出就变成了新的
浏览 5修改于2019-11-25得票数 3
回答已采纳
1回答
我在试着理解长生不老药流。...(5)> Enum.reduce(4, &+/2)226这里一切都很清楚，每个枚举都返回一个列表让我们用流构建它：...(4)> Stream.map(&
浏览 1提问于2016-02-21得票数 0
回答已采纳
1回答
getIOFromIO :: IO String -> IO String origContents <- orig
moreIO <-
浏览 1提问于2022-02-19得票数 0
回答已采纳
这个问题的背景是从一个流(IO绑定)读取数据，处理数据(CPU绑定)，然后写入另一个流(IO绑定)。thread 1: loop { |<--read data block from stream-->| enqueue data block to blocking queue A }
thread 3: loop { dequeue data block from blocking queue B |<--write to s
浏览 31修改于2020-05-07得票数 1
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号