我一直在想如何才能将Map[A, Seq[Future[Option[B]]]]转换为Future[Map[A, Seq[B]]]
浏览 32提问于2020-04-04得票数 0
回答已采纳
我有一个scala IndexedSeq[(Int, Future[Long])])。我想填写这个函数：Future.sequence(distances.map {
case
浏览 1提问于2014-06-25得票数 0
我有以下代码import scala.concurrent.duration.Duration
def seq[T](v: Option[Future[T]]): Future[Option[T]] = Future</em
浏览 2提问于2015-12-01得票数 2
回答已采纳
我想从DB异步加载它们，然后将每个记录异步上传到远程服务器，然后在所有上传完成后，记录所上传的记录的ids。由于我使用的是Scala 2.9.2，所以我使用的是Twitter的core-util Future实现，但它在一元转换方面的工作方式应该与2.10版完全相同。一般概念是这样的：def upload(record: Record): Future[String]
defnotifyUplo
浏览 0提问于2013-03-01得票数 8
如果没有未来，这就是我如何将所有较小的Seq与平台映射合并为一个大的Seq。category.getCategoryUrlKey(id: Int):Seq[Meta] // main methodlazy val breaker = new akka.pattern.CircuitBreaker
浏览 11提问于2017-06-16得票数 6
回答已采纳
import scala.concurrent.duration.Durationimport scala.concurrent{Await, Future}import scala.concurrent.ExecutionContext.Implicits.global[String] = Seq</em
浏览 4提问于2018-01-15得票数 0
回答已采纳
我正试图解决以下问题：下面是我到目前为止掌握的代码：
def getClientData(clientInfo: ClientInfo): Future[Clien
浏览 4提问于2013-12-03得票数 1
回答已采纳
我正在寻找一种将Seq[(A, Future[B])]转换为Future[Map[A,B]]的干净方法。有什么好方法可以做到这一点吗？提前感谢！
浏览 4提问于2016-02-09得票数 0
左连接的结果是：Future[Seq[(A, Option[B])]]，其中A是主表的类型，B是明细表的类型。换句话说，我得到了一个主元素A序列，重复的次数与B的左连接实例的次数相同。我想将这个复杂的重复类型简化为一个更易于管理的结果类型Future[Option[(A, Seq[B])]]。为此，我创建了以下函数： implicit def simplify[A, B](x: Future
浏览 21提问于2019-06-04得票数 0
回答已采纳
4回答
所有操作都具有相同的返回值(例如Seq[String])。我希望返回成功的结果和发生的任何异常，这样我就可以记录它们以进行调试。我正在考虑在自己的将来执行每个操作，然后检查每个未来，并返回一个Seq[String] -> Seq[Throwable]元组，其中左值是成功的结果(扁平/合并)，右边是发生的任何异常的列表。
浏览 0提问于2018-09-22得票数 1
回答已采纳
1回答
我试图编写一个值类，以向实现Seq[_]的任何东西添加功能，并允许它进行批处理调用，返回一个Future[_] (具体来说，我使用它进行批处理REST调用)。final class BatchedList[A, C[X] <: Seq[X]](val targetList: C[A]) extends AnyVal {
def batchRequests[B](batchSize: Int)(runner: Seq[A] => Seq[Future[E
浏览 3提问于2014-10-28得票数 0
回答已采纳
2回答
假设我已经收到了一份期货清单，其中每一份都与一个键相连，例如：我的目标是在所有期货完成后，生成一个关键价值元组的列表：我想知道这是否可以通过序列调用来实现。例如，我知道我可以做以下工作： case Success(s
浏览 3提问于2014-05-10得票数 1
回答已采纳
2回答
我绝对是Scala的初学者，但我有这个问题要解决。因此，我想为列表中的每个项目启动3个线程，然后将3个报告合并为1个最终报告，或者我可以按顺序执行。
如果列表中的每一项都有3个线程，我该怎么做呢？
浏览 4提问于2018-07-27得票数 2
回答已采纳
我想检查Future[SeqString]是否为空，并且我正在使用//doSomething但是它抛出了我的错误？
浏览 0提问于2013-04-04得票数 2
回答已采纳
1回答
我有下面的简单代码 val aa = l.map(_=>Future.successful(())) }
我可以很容易地理解这样一个事实:我正在返回Future[Unit] type corresponding to each element of my sequence "l"--因此很容易说"aa"是Seq<
浏览 2提问于2017-06-18得票数 1
回答已采纳
我有一个Seq[String]，需要这些字符串值来调用另一个定义为：我正在尝试创建一个函数，它接受Seq[String]并返回Future[Seq[Something]]；也就是说，
def getSomethings(ids: Seq[String]): Future[Seq[Something]有什么方法可以在Seq[Strin
浏览 1提问于2018-05-07得票数 0
回答已采纳
object Test {
val list = Seq(future { println("startFirst"); Thread.sleep(3000); println("stopFirst") },
future { println("startSecond"); Thread.sleep(1000); println(&
浏览 2提问于2014-07-31得票数 47
回答已采纳
如何将Future[Option[Future[Option[X]]]]转换为Future[Option[X]]？def processAndReturnFuture(x:String):Future[String] = future(x)
def processAgainAndReturnOption(x:St
浏览 0提问于2013-10-18得票数 5
回答已采纳
本质上，这项工作只是将分层的XML结构转换为6组平面CSV记录。为了做到这一点，我目前六次忽略了相同的RDD 6。val rddofTypeB = xmlRdd.map { iterate over XML Object and create Type B} rddOfTypeC.saveAsT
浏览 0提问于2017-11-26得票数 2
我在下面的函数中使用了EitherT[Future, Failure, Option[B]]，该函数执行foldLeft。如何在下面的代码中设置foldLeft的初始值？def doWork[A, B](seq: Set[A])(f: A => EitherT[Future, Failure, Option[B]]): EitherT[Future, Failure,Set[Option[B
浏览 6提问于2019-07-16得票数 0
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
