stream

2热度

2回答

我想以异步方式读取文件夹中的许多.CSV文件，并返回一个自定义案例类的Iterable。我可以通过Akka Streams和How？实现吗？ *我试图根据文档以某种方式平衡工作，但它是一个有点难以管理，通过... 或者这是一个好的做法是使用替代演员？（父母演员带孩子，每个孩子读一个文件，并返回一个Iterable到父母，然后父母结合所有Iterables？）

0热度

1回答

如何内部加入2通过Akka Scala中的密钥来源？

我有2个来源，如： val s1: Source[(Int, String)] = ... val s2: Source[(Int, String)] = ... 是否有可能内部连接它们，最后得到这样的： val sink: Sink[(Int, String), Future[Iterable[(Int, Iterable[String])]]] = ???

-1热度

1回答

C＃BinaryReader工作怪异

当我拨打ReadByte时，执行覆盖的Read方法。代码是在这里 public object Read(Stream s) { Issues.Clear(); if (AutoReset) Reset(); using (var r = new BinaryReader(s, Encoder, true)) { // chec

0热度

1回答

Java套接字 - 接收不同对象的客户端

所以我想用Java套接字在Java中制作一个纸牌游戏。我有这个“PlayerState”对象，它保持所有在大厅或准备玩的玩家。问题是，即使服务器发送相同的对象为所有客户，所有客户端收到不正确的数据不同的对象......让我来解释因此，这是在服务器，发送对象的方法： private void sendToAll(PlayersState playersState){ resetLists

1热度

1回答

在节点上传视频到url

在我的应用程序中，我想将视频发布到多个网络（fb，twitter ...），我将视频上传到cloudinary并发回了url，我用它发布到fb。对于twitter，无法使用网址发布视频。有没有其他办法可以做到这一点？我的服务器尺寸很低，比如1-2GB，所以我无法将视频下载到我的服务器，然后创建一个要上传到Twitter的流。我担心，如果3-4个用户开始上传，那么我的服务器将因内存不足而崩溃。

0热度

1回答

管道改造或可读流process.stdout

我有以下代码： const pt = require('prepend-transform').default; const writable = pt('[test-process]').pipe(process.stdout); 写的是这是process.stdout在目的地流，因此，如果我写的写，我只是得到标准输出，不'[测试过程]'预先添加到每一行。请注意，pt(x)返回一个变换流。

0热度

1回答

从FastReport中的Stream创建的文件加载报告

有一种方法可以构建报告。它在服务器上生成流，然后将其保存到tmp文件。 public virtual void Build(ReportType reportType, ReportParameters parameters) { Export = reportType.Id == MaterialReportIds.WarehouseBalanceDynamic; v

0热度

1回答

如何在RxJs 5中将项目分组为大小为n的组？

我需要帮助将无限数据流上的项目分组而不会丢失数据。组的大小必须不大于n个元素。如果在一段时间内没有物品出现，那么当前组的大小可能小于n。试图验证码： Observable.create(observer => { setTimeout(() => observer.next([1]), 90) setTimeout(() => observer.next([2, 3])

0热度

1回答

如何隐藏网络播放器中的音乐地址？

如何隐藏音乐地址（音乐/ stream.mp3）？我不希望听众看到音乐的地址，可以下载！我有一个音乐流的网站，听众不应该能够下载音乐。 <audio controls> <source src="music/stream.mp3" type="audio/mpeg"> Your browser does not support the audio element. </audio

0热度

1回答

在一种方法上同时使用await /异步和线程是否可行？

我是多线程新手，我有一个关于同时使用线程和等待/异步的（可能）简单问题。我有一个方法读取TCP流，然后处理它收到的响应。它被称为时尚显示如下： ThreadStart ts = new ThreadStart(ReadTCP); Thread tt = new Thread(ts); 它是可行的从流异步读取数据？像这样的代码： private async void ReadTCP()