2

いくつかのブロッキング呼び出しを でラップしようとしていFutureます。戻り値の型はSeq[User]です。以下は、さまざまなオーバーロードされたバージョンが存在するという苦情でコンパイルされません。助言がありますか？私はほとんどすべてのバリエーションを試しましたが、運がありません。Usercase classSource.apply

// All I want is Seq[User] => Future[Seq[User]]

def findByFirstName(firstName: String) = {
  val users: Seq[User] = userRepository.findByFirstName(firstName)

  val sink = Sink.fold[User, User](null)((_, elem) => elem)

  val src = Source(users) // doesn't compile

  src.runWith(sink)
}
4

2 に答える 2

3

Future[Seq[Users]] だけが必要な場合は、akka ストリームを使用せずに 先物を使用します

import scala.concurrent._
import ExecutionContext.Implicits.global
val session = socialNetwork.createSessionFor("user", credentials)
val f: Future[List[Friend]] = Future {
  session.getFriends()
}
于 2015-09-10T07:31:14.763 に答える