singlethread.scala

import org.reactivecouchbase.ReactiveCouchbaseDriver
import scala.concurrent.Future
import play.api.libs.json._

object Application extends App {

  val driver = ReactiveCouchbaseDriver()
  val bucket = driver.bucket("default")
  implicit val ec = ExecutionContext.fromExecutor(Executors.newSingleThreadExecutor())
  implicit val keys = Seq("key-1", "key-2", "key-3")

  Future.sequence(keys.map(key => bucket.get[JsObject](key))).map { listOfDocs =>
    // TODO : whatever you need to do ...
  }.andThen {
    case _ => driver.shutdown()
  }
}

When should I be using this and when should I be using rawFetch(keysEnumerator: Enumerator[String])