Проблема Создание потока Кинезиса с помощью Scalazon

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 (смотрите пример кода в библиотеке README).

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