-
scala – 使用喷雾客户端进行多次请求时的akka??超时
所属栏目：[安全] 日期：2020-12-16 热度：75
使用喷雾1.3.2和akka 2.3.6. (akka仅用于喷雾). 我需要读取大文件,并为每一行发出一个http请求. 我用迭代器逐行读取文件,并为每个项目发出请求. 它成功运行了一些线路,但有时它开始失败： akka.pattern.AskTimeoutException：在[60000 ms]之后询问[Actor [ak[详细]
-
将scalac插件拆分为多个文件
所属栏目：[安全] 日期：2020-12-16 热度：190
我想将我的 scalac插件拆分成多个文件.这听起来很容易,但由于导入global._行导致的路径依赖类型问题,我无法将其拉下来. 这是Lex Spoon的示例插件： package localhostimport scala.tools.nscimport nsc.Globalimport nsc.Phaseimport nsc.plugins.Pluginimpo[详细]
-
scala – 如何向列表添加选项
所属栏目：[安全] 日期：2020-12-16 热度：189
将选项添加到列表的最佳方法是什么. 这是我的第一次尝试： def append[A](as: List[A],maybeA1 : Option[A],maybeA2: Option[A]) : List[A] = as ++ maybeA1.toList ++ maybeA2.toList Con：它创建了2个tmp List (我知道.toList()是可选的,因为存在从Option[详细]
-
未找到Scala：解包返回元组时的值x
所属栏目：[安全] 日期：2020-12-16 热度：148
我在无数的网站上看到过这种代码但它似乎没有编译： def foo(): (Int,Int) = { (1,2)}def main(args: Array[String]): Unit = { val (I,O) = foo()} 它在标记的行上失败,报告： 没找到：值我 未找到：值O. 可能是什么原因造成的？ 解决方法 问题是在模式匹配[详细]
-
scala – 为什么在Option [T]的HList上映射不起作用？
所属栏目：[安全] 日期：2020-12-16 热度：63
这不编译,我不明白为什么： import shapeless._import poly._object option extends (Option ~ List) { def apply[T](t: Option[T]) = t.toList}val simple = Some(1) :: Some("hello") :: Some(true) :: HNilval opts: List[Int] :: List[String] :: List[B[详细]
-
scala – 具有自签名证书的Spray https服务器的配置问题？
所属栏目：[安全] 日期：2020-12-16 热度：86
我在Mac 10.9.4上使用Spray 1.3,Akka 2.3和 Scala 2.11来设置HTTP服务器.我跟随Ch. 2 Manning的Akka in Action中的示例(此处提供的示例代码： https://github.com/RayRoestenburg/akka-in-action.git),当我使用http时,它会按预期编译,运行和运行,但我无法将[详细]
-
scala – 如何在光滑的情况下为复杂的案例类创建投影类？
所属栏目：[安全] 日期：2020-12-16 热度：143
例如,我有这个案例类： case class User( var identityId: IdentityId,//Its a user created class var firstName: String,var lastName: String,var fullName: String,var email: Option[String],var avatarUrl: Option[String],var authMethod: Authentica[详细]
-
scala – 如何排除conf文件夹下的文件以进行分发？
所属栏目：[安全] 日期：2020-12-16 热度：96
我在Play 2.3应用程序的conf文件夹下有一个application.dev.conf和application.test.conf,但是我不希望它被打包成我的发行版的一部分？什么是正确的excludeFilter呢？ 解决方法 您可以使用映射来排除这两个文件. mappings in Universal := { val origMapping[详细]
-
scala – 通过键Scalding Hadoop写入多个输出,一个MapReduce作业
所属栏目：[安全] 日期：2020-12-16 热度：187
如何在单个Map Reduce作业中使用Scalding(/ cascading)写入依赖于键的多个输出.我当然可以使用.filter来获取所有可能的密钥,但这是一个可怕的黑客攻击,它将启动许多工作. 解决方法 Scalding中有 TemplatedTsv(从0.9.0rc16及更高版本开始),与Cascading Templa[详细]
-
scala – 找不到错误值上下文？
所属栏目：[安全] 日期：2020-12-16 热度：190
def join(username: String): scala.concurrent.Future[(Iteratee[JsValue,_],Enumerator[JsValue])] = { println("friend name in model" + username) val first = Akka.system.actorOf(Props[ChatRoom2],name = username) println("this is chat room two[详细]
-
scala – 当关键字在不同的上下文中表示不同的东西时,这是一个上
所属栏目：[安全] 日期：2020-12-16 热度：56
根据 this answer = Scala中的关键字有两个不同的含义：1表示函数类型：Double = Double和2创建一个lambda表达式：(x：Double)：Double = 2 * X. 这与正式语法有什么关系,即这会使Scala上下文敏感吗？ 我知道most languages are not context free,但我不确定[详细]
-
Scala模式匹配中的自动拆箱
所属栏目：[安全] 日期：2020-12-16 热度：182
在下面的代码中,我收到一个编译错误,指出我的’x’类型不匹配： val someRef: java.lang.Long = 42LsomeRef match { case x: Long = println("The answer: " + x) case _ = println("Unknown")} 如何让Scala在match语句中自动取消装箱someRef？ 解决方法 类[详细]
-
scala – 用于PlayFramework静态文件的nginx配置
所属栏目：[安全] 日期：2020-12-16 热度：81
我想将Nginx用于我的Play的服务器/资源文件夹！应用.我想要： 代理大部分文件播放！ 将点/资产指向本地文件夹 我使用以下配置,但它不起作用： worker_processes 1;error_log logs/error.log;events { worker_connections 1024;}http { include mime.types; d[详细]
-
scala – 在需要它们的类型的继承者中提供隐式实例
所属栏目：[安全] 日期：2020-12-16 热度：177
令我惊讶的是,我发现编译器无法解析以下示例中的隐含： trait API { def f(implicit a: Int) = ???}class Impl extends API { implicit val int = 2}(new Impl).f 以及在 class Impl extends APIobject Impl { implicit val int = 2} 我对此深感沮丧.为什么[详细]
-
Scala在哪里存储无法用Java表示的信息？
所属栏目：[安全] 日期：2020-12-16 热度：59
有些构造在 java中没有等价物.例子就是 命名参数 实例私人成员 Scala在哪里/如何存储这些东西所需的信息(第一种情况下是某种标志,第二种情况下是参数名称？ 如果我做对了,这必须存储在字节码中,因为即使我只有一个没有源代码的编译库,它也能工作！？ 解决方[详细]
-
在Scala Reflection中,为什么构造函数params会隐藏getter？
所属栏目：[安全] 日期：2020-12-16 热度：86
scala类中的变量自动获取getter你可以通过成员通过scala反射看到的setters import scala.reflect.runtime.{universe = ru}class A(var x: Int)scala ru.typeOf[A].members.filter{_.name.toString.contains("x")}res22: Iterable[reflect.runtime.universe.S[详细]
-
在Scala中讨论,使这些语句编译的类型是什么？
所属栏目：[安全] 日期：2020-12-16 热度：196
所以我在 Scala中有这个功能： def f(a: Int)(b: Int)(c: Double)(d: Double): Double = a * c + b * d 问题是使以下语句编译的三种类型是什么. def g: Type1 = f(1)(2)(3.0) def h: Type2 = f(1)(2) def k: Type3 = f(1) 我还是Scala的新手,我并不是真正理[详细]
-
scala – 了解DelayedInit
所属栏目：[安全] 日期：2020-12-16 热度：132
我在 Scala in Depth看DelayedInit …… 评论是我对代码的理解. 以下特征接受单个参数,该参数是非严格评估的(由于=),并返回Unit.它的行为类似于构造函数. trait DelayedInit { def delayedInit(x: = Unit): Unit} 据我了解App,这个特性的var x等于0-arity(无[详细]
-
scala – 将Akka TestKit与Specs2一起使用
所属栏目：[安全] 日期：2020-12-16 热度：190
我正在尝试使用Akka的TestKit进行specs2测试.我坚持一个持续的编译错误我无法弄清楚如何解决,我很感激建议. 编译错误是： TaskSpec.scala:40: parents of traits may not have parameters[error] with akka.testkit.TestKit( ActorSystem( "testsystem",Conf[详细]
-
scala – Akka,SQS和Camel的消费者民意调查
所属栏目：[安全] 日期：2020-12-16 热度：168
我正在研究的项目需要从SQS读取消息,我决定使用Akka来分发这些消息的处理. 由于SQS是Camel支持的,并且内置了在Consumer类中使用Akka的功能,我想最好以这种方式实现端点和读取消息,尽管我没有看到很多人这样做的例子. 我的问题是我不能足够快地轮询我的队列以[详细]
-
scala – sbt程序集任务在添加一些依赖项后运行缓慢
所属栏目：[安全] 日期：2020-12-16 热度：114
我对 scala中的部署有点新意,我配置了sbt-assembly插件,一切运行良好. 几天前我添加了hadoop,spark和其他一些依赖项,然后组装任务变得极其缓慢(8到10分钟),在此之前,它是 30秒.大部分时间用于生成程序集jar(jar需要几秒钟才能生成1MB大小). 我发现存在很多合[详细]
-
Scala函数定义参数列表中的不同括号样式
所属栏目：[安全] 日期：2020-12-16 热度：200
Scala中以下两个函数定义的区别是什么： 1)def sum(f：Int = Int)(a：Int,b：Int)：Int = { code removed } 2)def sum(f：Int = Int,a：Int,b：Int)：Int = { code removed } ？ SBT的控制台REPL为它们提供了不同的价值,因此看起来它们是否有所不同： sum：([详细]
-
从scala模板中的application.conf访问布尔值
所属栏目：[安全] 日期：2020-12-16 热度：138
我在application.conf中有一个布尔参数： system.debugMode = false 我正在尝试根据我的scala模板中的值进行分支： pDebug mode parameter value: @Play.current.configuration.getBoolean("system.debugMode")/p@if(Play.current.configuration.getBoolean([详细]
-
scala – 将包导入为另一个
所属栏目：[安全] 日期：2020-12-16 热度：70
假设我有一个包含com.example.a.b.c包含的大量案例类的 Scala项目.我想将所有这些类导入到一个包com.example.c(其中包含一些非冲突的case类),以便在我的项目中的任何其他地方,我只需要导入com.example.c._来使用每个来自com.example.c和com.example.abc的cas[详细]
-
我可以使用Sclick List和Slick(Play)吗？
所属栏目：[安全] 日期：2020-12-16 热度：113
我正试图在这里存储一个整数列表是我正在做的事情： 模型 case class Score( scoresPerTime: List[Int])object Scores extends Table[Score]("SCORES"){ def scorePerTime = column[List[Int]]("SCORE_PER_TIME") //...more code} 调节器 val form = Form( M[详细]
