Instance Constructors
-
new
ConsumerIterator
(channel: BlockingQueue[FetchedDataChunk], consumerTimeoutMs: Int, keyDecoder: Decoder[K], valueDecoder: Decoder[V], clientId: String)
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
++
[B >: MessageAndMetadata[K, V]]
(that: ⇒ GenTraversableOnce[B]): Iterator[B]
-
def
/:
[B]
(z: B)(op: (B, MessageAndMetadata[K, V]) ⇒ B): B
-
def
/:\
[A1 >: MessageAndMetadata[K, V]]
(z: A1)(op: (A1, A1) ⇒ A1): A1
-
def
:\
[B]
(z: B)(op: (MessageAndMetadata[K, V], B) ⇒ B): B
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
addString
(b: StringBuilder): StringBuilder
-
def
addString
(b: StringBuilder, sep: String): StringBuilder
-
def
addString
(b: StringBuilder, start: String, sep: String, end: String): StringBuilder
-
def
aggregate
[B]
(z: B)(seqop: (B, MessageAndMetadata[K, V]) ⇒ B, combop: (B, B) ⇒ B): B
-
-
def
asInstanceOf
[T0]
: T0
-
def
buffered
: BufferedIterator[MessageAndMetadata[K, V]]
-
def
clearCurrentChunk
(): Unit
-
val
clientId
: String
-
def
clone
(): AnyRef
-
def
collect
[B]
(pf: PartialFunction[MessageAndMetadata[K, V], B]): Iterator[B]
-
def
collectFirst
[B]
(pf: PartialFunction[MessageAndMetadata[K, V], B]): Option[B]
-
def
contains
(elem: Any): Boolean
-
def
copyToArray
[B >: MessageAndMetadata[K, V]]
(xs: Array[B], start: Int, len: Int): Unit
-
def
copyToArray
[B >: MessageAndMetadata[K, V]]
(xs: Array[B]): Unit
-
def
copyToArray
[B >: MessageAndMetadata[K, V]]
(xs: Array[B], start: Int): Unit
-
def
copyToBuffer
[B >: MessageAndMetadata[K, V]]
(dest: Buffer[B]): Unit
-
def
count
(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Int
-
def
debug
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
debug
(e: ⇒ Throwable): Any
-
def
debug
(msg: ⇒ String): Unit
-
-
-
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
error
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
error
(e: ⇒ Throwable): Any
-
def
error
(msg: ⇒ String): Unit
-
def
exists
(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Boolean
-
def
fatal
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
fatal
(e: ⇒ Throwable): Any
-
def
fatal
(msg: ⇒ String): Unit
-
-
-
def
finalize
(): Unit
-
-
def
flatMap
[B]
(f: (MessageAndMetadata[K, V]) ⇒ GenTraversableOnce[B]): Iterator[B]
-
def
fold
[A1 >: MessageAndMetadata[K, V]]
(z: A1)(op: (A1, A1) ⇒ A1): A1
-
def
foldLeft
[B]
(z: B)(op: (B, MessageAndMetadata[K, V]) ⇒ B): B
-
def
foldRight
[B]
(z: B)(op: (MessageAndMetadata[K, V], B) ⇒ B): B
-
def
forall
(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Boolean
-
def
foreach
[U]
(f: (MessageAndMetadata[K, V]) ⇒ U): Unit
-
def
getClass
(): java.lang.Class[_]
-
def
grouped
[B >: MessageAndMetadata[K, V]]
(size: Int): GroupedIterator[B]
-
def
hasDefiniteSize
: Boolean
-
def
hasNext
(): Boolean
-
def
hashCode
(): Int
-
def
indexOf
[B >: MessageAndMetadata[K, V]]
(elem: B): Int
-
def
indexWhere
(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Int
-
def
info
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
info
(e: ⇒ Throwable): Any
-
def
info
(msg: ⇒ String): Unit
-
def
isEmpty
: Boolean
-
def
isInstanceOf
[T0]
: Boolean
-
def
isTraversableAgain
: Boolean
-
def
length
: Int
-
var
logIdent
: String
-
lazy val
logger
: Logger
-
val
loggerName
: String
-
-
def
map
[B]
(f: (MessageAndMetadata[K, V]) ⇒ B): Iterator[B]
-
-
-
def
maybeComputeNext
(): Boolean
-
-
-
def
mkString
: String
-
def
mkString
(sep: String): String
-
def
mkString
(start: String, sep: String, end: String): String
-
def
ne
(arg0: AnyRef): Boolean
-
-
def
nonEmpty
: Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
def
padTo
[A1 >: MessageAndMetadata[K, V]]
(len: Int, elem: A1): Iterator[A1]
-
-
def
patch
[B >: MessageAndMetadata[K, V]]
(from: Int, patchElems: Iterator[B], replaced: Int): Iterator[B]
-
-
def
product
[B >: MessageAndMetadata[K, V]]
(implicit num: Numeric[B]): B
-
def
reduce
[A1 >: MessageAndMetadata[K, V]]
(op: (A1, A1) ⇒ A1): A1
-
-
-
def
reduceOption
[A1 >: MessageAndMetadata[K, V]]
(op: (A1, A1) ⇒ A1): Option[A1]
-
-
-
def
remove
(): Nothing
-
def
resetState
(): Unit
-
-
def
sameElements
(that: Iterator[_]): Boolean
-
def
scanLeft
[B]
(z: B)(op: (B, MessageAndMetadata[K, V]) ⇒ B): Iterator[B]
-
def
scanRight
[B]
(z: B)(op: (MessageAndMetadata[K, V], B) ⇒ B): Iterator[B]
-
-
def
size
: Int
-
def
slice
(from: Int, until: Int): Iterator[MessageAndMetadata[K, V]]
-
def
sliding
[B >: MessageAndMetadata[K, V]]
(size: Int, step: Int): GroupedIterator[B]
-
-
def
sum
[B >: MessageAndMetadata[K, V]]
(implicit num: Numeric[B]): B
-
def
swallow
(action: ⇒ Unit): Unit
-
def
swallowDebug
(action: ⇒ Unit): Unit
-
def
swallowError
(action: ⇒ Unit): Unit
-
def
swallowInfo
(action: ⇒ Unit): Unit
-
def
swallowTrace
(action: ⇒ Unit): Unit
-
def
swallowWarn
(action: ⇒ Unit): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
-
-
def
toArray
[B >: MessageAndMetadata[K, V]]
(implicit arg0: ClassManifest[B]): Array[B]
-
def
toBuffer
[B >: MessageAndMetadata[K, V]]
: Buffer[B]
-
def
toIndexedSeq
[B >: MessageAndMetadata[K, V]]
: IndexedSeq[B]
-
-
-
-
def
toMap
[T, U]
(implicit ev: <:<[MessageAndMetadata[K, V], (T, U)]): Map[T, U]
-
-
-
-
def
toString
(): String
-
def
toTraversable
: Traversable[MessageAndMetadata[K, V]]
-
def
trace
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
trace
(e: ⇒ Throwable): Any
-
def
trace
(msg: ⇒ String): Unit
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
def
warn
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
warn
(e: ⇒ Throwable): Any
-
def
warn
(msg: ⇒ String): Unit
-
-
def
zip
[B]
(that: Iterator[B]): Iterator[(MessageAndMetadata[K, V], B)]
-
def
zipAll
[B, A1 >: MessageAndMetadata[K, V], B1 >: B]
(that: Iterator[B], thisElem: A1, thatElem: B1): Iterator[(A1, B1)]
-
def
zipWithIndex
: Iterator[(MessageAndMetadata[K, V], Int)] { ... /* 2 definitions in type refinement */ }
Inherited from AnyRef
Inherited from Any
An iterator that blocks until a value can be read from the supplied queue. The iterator takes a shutdownCommand object which can be added to the queue to trigger a shutdown