Scala - fromPublisher不是對象的成員akka.stream.scaladsl.Source

我剛開始使用Scala（2.11.7）中的akka流（2.4.6）和slick（3.1.1）。我使用Intellij（不確定是否重要，但我認爲我會把它扔掉）。Scala - fromPublisher不是對象的成員akka.stream.scaladsl.Source

val scanner: DatabasePublisher[Stage] = db.stream(action.transactionally.withStatementParameters(fetchSize = 5000)) 
val source = Source.fromPublisher(scanner)

問題出在第二行。的IntelliJ告訴我，它無法解析符號「fromPublisher」 ......我認爲這是IJ是finnicky但是當我去打造我得到這個：

Error:(38, 10) value fromPublisher is not a member of object akka.stream.scaladsl.Source 
    Source.fromPublisher(scanner) 
     ^

什麼我可以做任何錯誤的想法？

一直與這整個晚上戰鬥，我準備把我的頭髮。

謝謝！

來源

2016-06-01 marco

你能顯示完整的代碼片段嗎 – Sky

見工作示例：

import akka.actor.ActorSystem 
import akka.stream.ActorMaterializer 
import akka.stream.scaladsl.Source 
import slick.backend.DatabasePublisher 
import slick.driver.H2Driver.api._ 

import scala.concurrent.Await 
import scala.concurrent.duration._ 

case class Emp(id: Int, name: String) 

object Demo extends App { 

    implicit val system = ActorSystem("Sys") 

    val db = Database.forConfig("h2mem1") 

    val empTableQuery = TableQuery[EmployeeTable] 
    val insertQuery = empTableQuery ++= Seq(Emp(1, "emp1"), Emp(2, "emp2"), Emp(3, "emp3"), Emp(4, "emp4")) 
    val action = DBIO.seq(empTableQuery.schema.create, insertQuery) 

    //create schema and insert record 
    Await.result(db.run(action), 1000 second) 
    // print db record 
    Await.result(db.run(empTableQuery.result), 1000 second).foreach(println) 
    val publisher: DatabasePublisher[Emp] = db.stream(empTableQuery.result) 

    import system.dispatcher 

    implicit val materializer = ActorMaterializer() 

    //consume using stream 
    println("Steaming data::::::::") 
    val source = Source.fromPublisher(publisher).map(emp => emp.id + " : " + emp.name).runForeach(println) 

    class EmployeeTable(tag: Tag) extends Table[Emp](tag, "emp") { 
    val id = column[Int]("id", O.PrimaryKey) 
    val name = column[String]("name") 

    def * = (id, name) <>(Emp.tupled, Emp.unapply) 
    } 


    source.onComplete(_ => system.terminate()) 

}

build.sbt

scalaVersion := "2.11.8" 

libraryDependencies ++= Seq(
    "mysql" % "mysql-connector-java" % "5.1.36", 
    "com.typesafe.slick" %% "slick-hikaricp" % "3.1.1", 
    "ch.qos.logback" % "logback-classic" % "1.1.3", 
    "com.typesafe.slick" %% "slick" % "3.1.1", 
    "com.typesafe.akka" %% "akka-stream" % "2.4.6", 
    "org.scalatest" %% "scalatest" % "2.2.5" % "test", 
    "com.h2database" % "h2" % "1.4.187" 
)

application.conf

h2mem1 = { 
    url = "jdbc:h2:mem:test1" 
    driver = org.h2.Driver 
    connectionPool = disabled 
    keepAliveConnection = true 
}

來源

2016-06-02 18:41:14 Sky

謝謝大家回答我的問題。我發現了這個問題。這不是代碼。

問題出在Intellij庫設置中。

我使用SBT編譯了這個項目，儘管事實上IJ正在全身心地投入工作，但它運行良好。

所以我戳了一下後，我進入了項目結構 - > SDK，我注意到在SDK庫中，akka-stream-experimental 1.0 jar和一大堆其他垃圾。

我刪除了那些（留下了JDK 8罐）。現在一切正常！

謝謝你！

來源

2016-06-03 18:08:12 marco

Scala - fromPublisher不是對象的成員akka.stream.scaladsl.Source

回答

相關問題