2015-02-07 68 views
0

我正在關注Scalazon示例here以創建Kinesis流。下面的代碼:問題使用Scalazon創建Kinesis流

val streamListFuture = for { 
    s <- Kinesis.streams.list 
} yield s 

提供了以下錯誤:

[error] KinesisStatsWriter.scala:51: value map is not a member of object io.github.cloudify.scala.aws.kinesis.Requests.ListStreams 
[error]  s <- Kinesis.streams.list 

如果我不使用的理解,並呼籲val createStream = Kinesis.streams.list,沒有錯誤。似乎無法弄清楚爲什麼。

同樣,下面的代碼位:

val createStream = for { 
    s <- Kinesis.streams.create(name) 
} yield s 

產生類似的錯誤:

[error] KinesisStatsWriter.scala:64: value map is not a member of io.github.cloudify.scala.aws.kinesis.Requests.CreateStream 
[error]  s <- Kinesis.streams.create(name) 

感謝幫助!

回答

1

作者在這裏,只有當您包含將請求隱式轉換爲Futures(它被稱爲ImplicitExecution)的模塊時,該理解才起作用。嘗試添加以下import語句(查看庫自述文件中的示例代碼)。

import io.github.cloudify.scala.aws.kinesis.Client.ImplicitExecution._