ウィキの非同期イテレータの例に従おうとしています
次のエラーが表示されます。
値スライスは play.api.libs.iteratee.Enumerator のメンバーではありません
問題が何であるかについての意見は大歓迎です。
これは、大規模なコレクションの結果をページ付けできるようにするためです
libraryDependencies ++= Seq(
"com.websudos" %% "phantom-dsl" % 1.22.0,
"com.websudos" %% "phantom-reactivestreams" % 1.22.0
)
import com.datastax.driver.core.{ResultSet, Row}
import com.websudos.phantom.CassandraTable
import com.websudos.phantom.dsl._
import com.websudos.phantom.iteratee.Iteratee
import org.dyne.danielsan.openblockchain.data.entity.Block
import scala.concurrent.Future
import com.websudos.phantom.reactivestreams._
import scala.concurrent.Await
import scala.concurrent.duration._
sealed class BlocksModel extends CassandraTable[BlocksModel, Block] {
override def fromRow(row: Row): Block = {
Block(
hash(row),
height(row)
}
object hash extends StringColumn(this) with PartitionKey[String]
object height extends IntColumn(this) with ClusteringOrder[Int] with Descending
object order_id extends LongColumn(this) with ClusteringOrder[Long] with Descending
abstract class ConcreteBlocksModel extends BlocksModel with RootConnector {
override val tableName = "blocks"
def getBlocks(start: Int, limit: Int): Future[Set[Block]] = {
select.fetchEnumerator.slice(start, limit).collect
}
}