问题使用Scalazon创建Kinesis流

Question

我正在关注Scalazon示例here以创建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) 

感谢帮助！

Answer 1

作者在这里，只有当您包含将请求隐式转换为Futures（它被称为ImplicitExecution）的模块时，该理解才起作用。尝试添加以下import语句（查看库自述文件中的示例代码）。

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