iterate相关内容

ReactiveMongo 是如何实现的，所以它被认为是非阻塞的?

阅读有关 Play 框架和 ReactiveMongo 的文档让我相信 ReactiveMongo 的工作方式是使用很少的线程并且从不阻塞. 然而，从 Play 应用程序到 Mongo 服务器的通信似乎必须在某个线程上发生.这是如何实施的?也非常感谢提供 Play、ReactiveMongo、Akka 等源代码的链接. Play 框架在此页面上包含一些关于此的文档关于线程池.开始了: ..
发布时间：2022-01-02 22:24:45 其他开发

无法理解 Play 2.0 中的 Iteratee、Enumerator、Enumeratee

我刚刚开始学习 Play 2.0 框架.我无法理解的一件事是 play 教程中描述的 Iteratee、Enumerator 和 Enumeratee 模式.我在函数式语言方面的经验很少. 这个模式有什么作用? 它如何帮助我编写非阻塞/响应式代码? 一些简单的例子会有所帮助. 解决方案 playframework 2.0 下载带有一些示例.其中两个有 Iteratee/C ..
发布时间：2022-01-02 22:18:38 其他开发

在 Play Scala 中使用迭代器和枚举器将数据流式传输到 S3

我正在 Scala 中构建一个 Play Framework 应用程序，我想在其中将字节数组流式传输到 S3.我正在使用 Play-S3 库来执行此操作.文档部分的“分段文件上传"与此处相关: //获取上传票val 结果:Future[BucketFileUploadTicket] =存储桶启动MultipartUpload BucketFile(fileName, mimeType)//上传零 ..
发布时间：2022-01-02 21:59:45 其他开发

为什么调用错误或在 BodyParser 的 Iteratee 中完成请求在 Play Framework 2.0 中挂起?

我正在尝试理解 Play 2.0 框架的反应式 I/O 概念.为了从一开始就获得更好的理解，我决定跳过框架的帮助程序来构建不同类型的迭代器，并从头开始编写一个自定义 Iteratee 以供 BodyParser 使用> 解析请求正文. 从 Iteratees 和 ScalaBodyParser 文档和两个关于响应式 I/O 的演示，这就是我想出的: import play.api.mvc. ..
发布时间：2022-01-02 21:39:47 其他开发

Play 2.x : 使用 Iteratees 进行响应式文件上传

我将从问题开始:如何使用 Scala API 的 Iteratee 将文件上传到云存储(在我的例子中是 Azure Blob Storage，但我不不认为现在最重要) 背景: 我需要将输入分成大约 1 MB 的块，以便将大型媒体文件 (300 MB+) 存储为 Azure 的 BlockBlobs.不幸的是，我的 Scala 知识仍然很差(我的项目是基于 Java 的，其中 Scala ..
发布时间：2021-12-09 08:19:14 其他开发

Scala:应用枚举后获取原始iteratee(播放文档中的示例未编译)

我想将一个枚举数应用于iteratee，然后再取回原来的iteratee，因此我可以再应用一些东西.播放文档中有一个示例，该示例使用Iteratee [Int，Int]来汇总其输入(http://www.playframework.org/documentation/2.0.1/Enumeratees).然后，他们使用Enumeratee [String，Int]允许输入类似"3"和"6"的字符串 ..
发布时间：2020-05-28 02:44:56 其他开发

如何基于合并规则将两个枚举器合并为一个

我们在Playframework上有一个Scala小项目.我正在尝试使所有事情变得被动，并偶然发现了一个问题. 我有两个Enumerator [A]实例，分别代表按日期排序的数据库中的值. 我需要将其作为单个Enumerator [A]并按日期顺序返回.我没有在Enumerator [A]中找到任何解决方案，因此我在单个集合中累积了A，然后对其进行排序. case class A( ..
发布时间：2020-05-04 05:17:42 Java开发

熊猫使用itertuples编辑单元格值

我想加快我的代码的速度，所以我不喜欢将double用于: 我的代码: for c in range(0, n-1): for l in range(0,n-c-1): df2.ix[l,c]=C_back(l,c,df) 我想使用 for x in df.itertuples(): 但是我不知道如何修改特定的单元格值. 谢谢 ..
发布时间：2020-05-04 05:02:20 Python

在Scala中使用惰性评估或融合进行迭代?

我听说迭代者是懒惰的，但是他们到底有多懒惰?另外，是否可以将迭代器与后处理功能融合在一起，从而不必构建中间数据结构? 例如，我是否可以在我的iteratee中从java.io.BufferedReader 构建一百万个项目Stream[Option[String]] ，然后以合成的方式过滤掉None，而无需整个Stream要保存在内存中?同时确保我不会炸毁烟囱吗?或类似的东西-不必使用Str ..
发布时间：2020-05-04 04:53:00 其他开发

如何理解play2中的`Iteratee`?

play2中有一个程序包play.api.libs.iteratee，其中有一个大对象Iteratee，该行有1000多行. 为什么play2需要这么大的物体以及如何理解它? 解决方案 我刚刚写了一篇文章，试图为那些试图发现Play2的人解释Play2提供的Iteratees的概念. http://mandubian.com/2012/08/27/对正常人的理解-播放2-迭代/ ..
发布时间：2020-05-04 04:52:03 其他开发

如何实现ReactiveMongo，以便将其视为非阻塞?

阅读有关Play框架和ReactiveMongo的文档使我相信ReactiveMongo的工作方式是使用很少的线程，并且永远不会阻塞. 但是，似乎从Play应用程序到Mongo服务器的通信必须发生在某个地方的某个线程上.如何实施?还将非常感谢您链接到Play，ReactiveMongo，Akka等源代码. 此页面上的Play框架包含与此有关的一些文档关于线程池 .它开始于: 从下 ..
发布时间：2020-05-04 04:50:56 其他开发

无法理解Play 2.0中的Iteratee，Enumerator，Enumeratee

我刚刚开始学习Play 2.0框架.我无法理解的一件事是播放教程中描述的Iteratee，Enumerator和Enumeratee模式.我对功能语言的经验很少. 此模式完成什么工作? 它如何帮助我编写非阻塞/反应式代码? 一些简单的示例会有所帮助. 解决方案 playframework 2.0下载附带了一些示例.其中两个具有Iteratee/Comet示例.例如，彗星时 ..
发布时间：2020-05-04 04:49:20 其他开发

在Play Framework WebSockets中广播消息

我正在使用Concurrent.unicast[JsValue]在Play Framework WebSockets中推送消息，并且我想优化向多个用户发送同一条消息的过程.可以使用多个Concurrent.Channel广播消息吗? 解决方案 简短答案 为每个用户维护单独的频道，并具有与用户相关联的组 好答案 package controllers import akk ..
发布时间：2020-05-04 04:32:03 其他开发

使用Scalaz Stream解析任务(替换Scalaz Iteratees)

简介 我在许多项目中使用 Scalaz 7 的迭代器，主要用于处理大型文件.我想开始切换到Scalaz streams ，该流旨在替换iteratee软件包(坦率地说，它缺少很多内容)的碎片，使用起来有点痛苦. 流基于 机器 (迭代概念的另一种变体)，它们具有在Haskell中也实现了.我曾经使用过Haskell机器库，但是机器和流之间的关系并不十分明显(至少对我而言)，并且流库的文档 ..
发布时间：2020-05-04 04:27:14 其他开发