trait Sequencer[Ops, Res] extends AnyRef
Typeclass for easy merging ("sequencing") of multiple RedisBatch instances into one. This is done in order to guarantee that some set of operations is sent to Redis as a single batch (most likely single network message).
The parameter Ops
represents batches that will be sequenced into one. It may be a collection, a tuple or
any other "collection-like" type for which type class instance is provided.
Res
is the type of result of the batch created by "sequencing". This type is automatically inferred from
the Ops
type. For example, if Ops
is (RedisBatch[Int], RedisBatch[String])
(tuple) then Res
will be
(Int, String)
. If Ops
is List[RedisBatch[Int]]
then Res
will be List[Int]
.
Nesting is also possible. For example, if Ops
is (List[RedisBatch[Int]], RedisBatch[String])
then
Res
will be (List[Int], String)
.
In order to perform "sequencing", simply call sequence on your collection of batches, e.g.
import RedisApi.Batches.StringTyped._ val tupleBatch: RedisBatch[(Long, Opt[String])] = (incr("key1"), get("key2")).sequence val listBatch: RedisBatch[List[Long]] = List("key1", "key2").map(key => incr(key)).sequence
- Annotations
- @implicitNotFound( ... )
- Alphabetic
- By Inheritance
- Sequencer
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Abstract Value Members
- abstract def sequence(ops: Ops): RedisBatch[Res]
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )