1

ウィキの非同期イテレータの例に従おうとしています

次のエラーが表示されます。

値スライスは 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
  }
}
4

1 に答える 1