DataSource

abstract def elements(): Op[Seq[Op[T]]]

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def cached[R1 >: DataSource[T, V], T1 >: T](implicit server: Server, bf: CanBuildSourceFrom[DataSource[T, V], T1, R1]): R1

def clone(): AnyRef

def combine[T1 >: T, B, That](dss: Seq[DataSource[T1, _]])(f: (Seq[T1]) ⇒ B)(implicit bf: CanBuildSourceFrom[DataSource[T, V], B, That]): That

def combine[B, C, That](ds: DataSource[B, _])(f: (T, B) ⇒ C)(implicit bf: CanBuildSourceFrom[DataSource[T, V], C, That]): That

def combineOp[T1 >: T, B, That](dss: Seq[DataSource[T1, _]])(f: (Seq[Op[T1]]) ⇒ Op[B])(implicit bf: CanBuildSourceFrom[DataSource[T, V], B, That]): That

def combineOp[B, C, That](ds: DataSource[B, _])(f: (Op[T], Op[B]) ⇒ Op[C])(implicit bf: CanBuildSourceFrom[DataSource[T, V], C, That]): That

def converge[B](f: (Seq[T]) ⇒ B): ValueSource[B]

def converge(): ValueSource[V]

def distribute[T1 >: T, That](cluster: ActorRef)(implicit bf: CanBuildSourceFrom[DataSource[T, V], T1, That]): That

def distribute[T1 >: T, That](implicit bf: CanBuildSourceFrom[DataSource[T, V], T1, That]): That

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

def foldLeft[B](z: B)(folder: (B, T) ⇒ B): ValueSource[B]

def foldRight[B](z: B)(folder: (T, B) ⇒ B): ValueSource[B]

def get(implicit server: Server): V

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def map[B, That](f: (T) ⇒ B)(implicit bf: CanBuildSourceFrom[DataSource[T, V], B, That]): That

apply a function to elements, and return the appropriate datasource *

def mapOp[B, That](f: (Op[T]) ⇒ Op[B])(implicit bf: CanBuildSourceFrom[DataSource[T, V], B, That]): That

apply a function to element operations, and return the appropriate datasource *

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def reduce[T1 >: T](reducer: (T1, T1) ⇒ T1): ValueSource[T1]

def reduceLeft[T1 >: T](reducer: (T1, T) ⇒ T1): ValueSource[T1]

def reduceRight[T1 >: T](reducer: (T, T1) ⇒ T1): ValueSource[T1]

def run(implicit server: Server): OperationResult[V]

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit