])
for{ eventualInvoices: Seq[Future[Seq[Invoice]]] = customers.map(customer => findInvoicesByCustomer}def findCustomers:
浏览 18提问于2019-08-05得票数 0
3回答
我想并行推出两个或两个以上的未来/承诺，即使其中一个启动的未来/承诺失败，而不想等待其余的完成。在Scala中编写这个管道的最常用的方法是什么。下面是更精确的示例代码。这些命令并不完全是cat和tail。我用它们是为了简洁。val future1 = Future { executeShellCommand("cat
浏览 7提问于2016-09-11得票数 6
回答已采纳
2回答
是块吗？
、
当涉及到未来时，我似乎找不到任何关于foreach在Scala中的行为的确切文档。例如，在下面的片段中： val mySeq: Future[Seq[Int]] = Future(Seq(1,2,3,4)) Future(1)未来(1)只有在前景完成后
浏览 6提问于2020-02-11得票数 0
回答已采纳
它返回一个未来描述结果的删除操作。在未来的未来上调用flatMap()将产生一个相当神秘的错误消息： found : reactivemongo.api.collections.bson.BSONCollection=> scala.concurrent.Future[x$5.BatchCommands.FindAndModifyCommand.FindAndModifyResult] forSome { va
浏览 0提问于2019-02-12得票数 2
回答已采纳
我有一个scala IndexedSeq[(Int, Future[Long])])。我想填写这个函数：如果不存在Long大于0的元素，则应返回Future of None。如果存在Long大于0的元素，则应返回最小关联Int的Future。这就是我现在得到的：
Futur
浏览 1提问于2014-06-25得票数 0
我有一片郁金香：我想要：
val futureSeqTuple: Future[Seq[(String, String)]] = Future(Seq
浏览 0提问于2018-03-06得票数 6
回答已采纳
在这段代码中，我需要打印变量seq，但是因为它是在处理期货之前打印的，所以它是空打印的。在执行语句println(seq)之前，如何等待变量seq被填充？object TestFutures5 extends App {
val seq = Seq[Int]()for ( x <- 1 to 10 ) {
val future2 =
浏览 3提问于2017-06-19得票数 0
回答已采纳
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
浏览 3提问于2014-10-28得票数 0
回答已采纳
我正在研究Scala期货，无意中发现了下面的代码： def await[T](f: Future[T]) = Await.result(f,10.seconds)
def g(n: Int): Future[Int] = Future): T => Future[T] = {
f.redu
浏览 3提问于2020-06-08得票数 1
回答已采纳
import ing.wbaa.druid.SQLQuery
import scala.util.splittedQueryList.parval hello = temp.map(x=> executeQuery(query, x)).seq
但是hello得到的不是值，而是()。
浏览 0提问于2020-10-30得票数 1
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
回答已采纳
def findUserGames(id: UserId): Future[Seq[(GameId, Score)]] = ???def findGames(id: UserId): Future[Seq[(Game, Score)]] = { val games: Future[Seq[Game]] = userGames.flat
浏览 0提问于2020-12-08得票数 1
在这种情况下，我的实践是使用.sequence将F[G[A]]转换为G[F[A]]。然后使用Await.result(future_of_a_list, time_out)获得结果。
浏览 3提问于2017-01-16得票数 2
回答已采纳
1回答
嗨，我是scala的新手，我有样品在做。 Future.successful(Seq(User(id = 1), User(id = 2)))
def get
浏览 1提问于2018-05-12得票数 0
回答已采纳
2回答
当一个函数依赖于一些未来的结果时，我一次又一次地挣扎。这通常归结为未来[Seq[FutureMyObject]]这样的结果。看上去像这样 val ideas: Future[Seq[Idea]] =由于对数据库的调用，getShortInfo自然会产生一个未来。为了减少findAll中的嵌套，我使用了Awai
浏览 4提问于2013-11-29得票数 22
回答已采纳
我在一个范围上执行一个for循环，这会产生一个可选结果的未来。我希望结果集合只包含非可选项。但我只剩下了Future[Seq[Option[Result]]]val result = for { }it exists and then and map to String... s map {
string => Result(<em
浏览 0提问于2018-10-22得票数 0
回答已采纳
import scala.concurrent.duration.Durationimport scala.concurrent{Await, Future}import scala.concurrent.ExecutionContext.Implicits.global[String] = Seq</em
浏览 4提问于2018-01-15得票数 0
回答已采纳
1回答
我有一个Scala应用程序，它使用多个数据源并合并合并的输出，该应用程序并行调用多个HTTP调用并等待结果，当所有结果都得到解决时，它将它们的输出合并到一个结果对象中，并将响应作为Scala Future[T](futures: Seq[Future[T]])(implicit ec: CustomExecutionContext): Future[Seq[Try[T]]] =
浏览 1提问于2018-10-18得票数 1
给定两个Future[Option[Int]]x: scala.concurrent.Future= Future.successful { Some(55) }
y: scala.concurrent.Future[Option[Int]] = <
浏览 3提问于2015-07-29得票数 0
下面的Haskell代码使用par和pseq来做一些多核数字运算，以显示正在使用的几个核心。在Scala中表达这一点最简单、最地道的方式是什么？
浏览 0提问于2013-04-03得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
实时音视频活动推荐
腾讯云开发者
