《scala》专题

我有下面一行代码: 但是，编译器会发出警告： scala.collection中任何类型模式的非变量类型参数。Set[Any]未选中，因为它通过擦除[warn]消除 很公平。 所以我把我的台词改成这样: 现在我得到一个错误： 找到[错误]：scala.collection.Set[_] [错误] 必需：scala.collection.Set[Any] 这两者有什么区别？ 然后我将代码更改为以下内

假设我有一个函数，它调用一个阻塞可中断操作。我想在超时的情况下异步运行它。也就是说，我想在超时到期时中断函数。 所以我正在尝试做这样的事情： 问题是 （1） 中的 可以为 null，因为 （2） 尚未将其设置为当前线程。在这种情况下，我想等到 设置完毕。最好的方法是什么？

我有一个Scala future，它调用一个api并返回future，如果结果不正确，那么另一个api调用将与第一个future的结果一起提交并作为future返回。 这是我目前为止所拥有的。 但是如果我访问fut2结果，它会给出这样的结果: 有没有一种方法，我可以选择返回fot2，如果fot1的结果是不准确的？ 编辑：第二个未来必须使用第一个未来来继续API调用。这就是我到目前为止所拥有的。

是否有可能“反转”Scala的未来？ 有时候，未来成功的结果意味着错误。在这种情况下，翻转一个未来会很好，即调用一个返回未来的函数，如果最初的未来失败，则该函数以指定的值成功，如果最初的未来成功，则以指定的错误失败。

我试图验证方法的参数是否为空，但我没有找到解决方案。。。 有人可以告诉我该怎么做吗？ 我正在尝试这样的事情：

我想创建一个独立的scala代码，使用自定义设置在MongoDB网站上使用该代码从MongoDB读取。 当我运行SBT包时，我会遇到一些错误。我猜这与SparkSession的错误创作方法有关。你能给我一个提示来修理它吗？ 我的内容 Firstapp.scala代码 以及运行后的错误 编辑1： 我尝试了这个解决方案，但没有正确编译。内容同上。我改变了转换为： 汇编结果如下： 编辑2： 我添加了to

在下面的示例中，我得到异常 当检查< code>if( i == 2 )失败时，我希望得到结果< code>Future( Test2 )。我如何在一个处理组合未来的for理解中处理filter/if？ 下面是一个在Scala REPL中工作的简化示例。 代码：

有没有可能实现这样的事情: 我希望清楚我的意图是什么。

我正在尝试编写一个从存储库读取的函数（返回，其中是未来），然后将其转换为。函数 采用 并返回 。我试图这样做是为了理解，但我的问题是该函数返回而不是。我做错了什么？任何帮助都会很棒！ 注意：已验证的Nel是猫的数据类型

在我的Play web应用程序中，我使用的是从未来获取结果。有没有其他更好的方法（使用最佳实践）从数据库中获得结果？如果我使用或我的控制器完成执行，结果还不在中。下面是我的控制器方法。一切正常，但我需要在Scala中遵循更多的最佳实践。 编辑：我已经在使用。但在这个例子中，我不能使用，基本上是因为。我想在验证json之前，我需要一个来包围该方法的所有代码。 使用平面地图和map的新方法。我的问题是

我一直在使用Scala的Play框架，但遇到了一些麻烦。 我试图从控制器方法调用另一个控制器方法。起初，我试图使用WSRequest/响应来调用其他控制器方法的路由，但是WS响应不包含任何内容！没有Cookies或标头，即使控制器的方法会返回重定向。 此外，我不确定如何直接调用Controller方法，因为它返回一个EssentialAction，但第一个方法使用隐式请求ActionAsync方法

我正在努力理解这个概念。我清楚地了解期货是什么。我对Promises有点困惑。下面的代码片段： 现在，以下两个代码片段之间有什么区别？ 和 我对第一个的理解是，p成功将完成与该p相关的未来计算。计算是异步的吗？这与使用 Future 块完成与 Promise p 关联的 Future f 的第二个代码片段有何不同？

我启动了几个异步进程，如果需要，这些进程反过来可以启动更多的进程（想想遍历目录结构或类似的东西）。每个进程都会返回一些东西，最后我想等待所有这些进程的完成，并安排一个函数来处理结果集合。 我的解决方案尝试使用可变的（我不断添加我生成的期货）和来安排一些函数在此缓冲区中列出的所有这些期货完成后运行。 我准备了一个简单的例子来说明这个问题： 它首先调度和期货，然后将在1秒后的分辨率中调度。本身将在2秒

我在Scala中为期货编写了许多不同的单元测试。所有异步调用都使用执行上下文。为了确保异步调用始终以相同的顺序执行，我需要延迟一些任务，这相当困难并且会减慢测试速度。执行程序可能仍（取决于其实现）先完成某些任务，然后再完成其他任务。 测试具有特定执行顺序的并发代码的最佳方式是什么？例如，我有以下测试用例: 其中delay是< code > def delay()= thread . sleep(4