使用 Scalazon 创建 Kinesis Stream 的问题答案

【问题标题】：Issue Creating Kinesis Stream with Scalazon使用 Scalazon 创建 Kinesis Stream 的问题
【发布时间】：2015-02-07 00:08:15
【问题描述】：

我正在关注here 的 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

如果我不使用 for 理解并调用 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)

感谢您的帮助！

【问题讨论】：

标签： scala amazon-kinesis scalazon

【解决方案1】：

这里的作者，仅当您包含将请求隐式转换为Futures（称为ImplicitExecution）的模块时，for-comprehension 才有效。尝试添加以下 import 语句（查看库 README 中的示例代码）。

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

【讨论】：