Package org.apache.pekko.util

Class ByteIterator.MultiByteArrayIterator

java.lang.Object

org.apache.pekko.util.ByteIterator

org.apache.pekko.util.ByteIterator.MultiByteArrayIterator

All Implemented Interfaces:

scala.collection.BufferedIterator<Object>, scala.collection.IterableOnce<Object>, scala.collection.IterableOnceOps<Object,scala.collection.Iterator,scala.collection.Iterator<Object>>, scala.collection.Iterator<Object>

Enclosing class:

ByteIterator

public static class ByteIterator.MultiByteArrayIterator
extends ByteIterator

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.util.ByteIterator

ByteIterator.ByteArrayIterator, ByteIterator.ByteArrayIterator$, ByteIterator.MultiByteArrayIterator, ByteIterator.MultiByteArrayIterator$

Nested classes/interfaces inherited from interface scala.collection.Iterator

scala.collection.Iterator.GroupedIterator<B extends Object>, scala.collection.Iterator.SliceIterator<A extends Object>

Constructor Summary

Constructors

Constructor	Description
MultiByteArrayIterator()

Method Summary

Modifier and Type	Method	Description
final ByteIterator	$plus$plus(scala.collection.IterableOnce<Object> that)
InputStream	asInputStream()	Directly wraps this ByteIterator in an InputStream without copying.
final void	clear()
final ByteIterator.MultiByteArrayIterator	clone()
final <B> int	copyToArray(Object xs, int start, int len)
int	copyToBuffer(ByteBuffer buffer)	For performance sensitive code, call copyToBuffer() directly on ByteString (it's optimised there)
final ByteIterator.MultiByteArrayIterator	drop(int n)	For performance sensitive code, call drop() directly on ByteString (it's optimised there)
final ByteIterator.MultiByteArrayIterator	dropWhile(scala.Function1<Object,Object> p)
<U> void	foreach(scala.Function1<Object,U> f)
ByteIterator.MultiByteArrayIterator	getBytes(byte[] xs, int offset, int n)	Get a specific number of Bytes from this iterator.
ByteIterator.MultiByteArrayIterator	getDoubles(double[] xs, int offset, int n, ByteOrder byteOrder)	Get a number of Doubles from this iterator.
ByteIterator.MultiByteArrayIterator	getFloats(float[] xs, int offset, int n, ByteOrder byteOrder)	Get a number of Floats from this iterator.
ByteIterator.MultiByteArrayIterator	getInts(int[] xs, int offset, int n, ByteOrder byteOrder)	Get a number of Ints from this iterator.
ByteIterator.MultiByteArrayIterator	getLongs(long[] xs, int offset, int n, ByteOrder byteOrder)	Get a number of Longs from this iterator.
ByteIterator.MultiByteArrayIterator	getShorts(short[] xs, int offset, int n, ByteOrder byteOrder)	Get a number of Shorts from this iterator.
protected final <A> ByteIterator.MultiByteArrayIterator	getToArray(Object xs, int offset, int n, int elemSize, scala.Function0<A> getSingle, scala.Function3<Object,Object,Object,scala.runtime.BoxedUnit> getMult)
final boolean	hasNext()
final byte	head()
final int	len()
final byte	next()
final int	size()
final ByteIterator.MultiByteArrayIterator	take(int n)	For performance sensitive code, call take() directly on ByteString (it's optimised there)
final ByteIterator.MultiByteArrayIterator	takeWhile(scala.Function1<Object,Object> p)
final ByteString	toByteString()

Methods inherited from class org.apache.pekko.util.ByteIterator

duplicate, foldLeft, getByte, getBytes, getBytes, getByteString, getDouble, getDoubles, getFloat, getFloats, getInt, getInts, getLong, getLongPart, getLongs, getShort, getShorts, indexOf, indexOf, indexOf, indexOf, indexWhere, indexWhere$default$2, slice, span, toArray, toSeq

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.collection.BufferedIterator

buffered, headOption

Methods inherited from interface scala.collection.IterableOnce

knownSize, stepper

Methods inherited from interface scala.collection.IterableOnceOps

$colon$bslash, $div$colon, addString, addString, addString, aggregate, collectFirst, copyToArray, copyToArray, copyToBuffer, corresponds, count, exists, find, fold, foldRight, forall, isTraversableAgain, max, maxBy, maxByOption, maxOption, min, minBy, minByOption, minOption, mkString, mkString, mkString, nonEmpty, product, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRight, reduceRightOption, reversed, splitAt, sum, to, toBuffer, toIndexedSeq, toIterator, toList, toMap, toSet, toStream, toVector

Methods inherited from interface scala.collection.Iterator

$plus$plus, collect, concat, contains, distinct, distinctBy, filter, filterImpl, filterNot, flatMap, flatten, grouped, hasDefiniteSize, isEmpty, iterator, length, map, nextOption, padTo, partition, patch, sameElements, scanLeft, scanRight, seq, sliceIterator, sliding, sliding$default$2, tapEach, toString, withFilter, zip, zipAll, zipWithIndex

Constructor Details

MultiByteArrayIterator

public MultiByteArrayIterator()

Method Details

clear

public final void clear()

Specified by:

clear in class ByteIterator

hasNext

public final boolean hasNext()

head

public final byte head()

Specified by:

head in interface scala.collection.BufferedIterator<Object>

Specified by:

head in class ByteIterator

next

public final byte next()

Specified by:

next in interface scala.collection.Iterator<Object>

Specified by:

next in class ByteIterator

len

public final int len()

Specified by:

len in class ByteIterator

size

public final int size()

$plus$plus

public final ByteIterator $plus$plus(scala.collection.IterableOnce<Object> that)

Overrides:

$plus$plus in class ByteIterator

clone

public final ByteIterator.MultiByteArrayIterator clone()

Overrides:

clone in class ByteIterator

take

public final ByteIterator.MultiByteArrayIterator take(int n)

For performance sensitive code, call take() directly on ByteString (it's optimised there)

Specified by:

take in interface scala.collection.IterableOnceOps<Object,scala.collection.Iterator,scala.collection.Iterator<Object>>

Specified by:

take in interface scala.collection.Iterator<Object>

Overrides:

take in class ByteIterator

drop

public final ByteIterator.MultiByteArrayIterator drop(int n)

For performance sensitive code, call drop() directly on ByteString (it's optimised there)

Specified by:

drop in interface scala.collection.IterableOnceOps<Object,scala.collection.Iterator,scala.collection.Iterator<Object>>

Specified by:

drop in interface scala.collection.Iterator<Object>

Overrides:

drop in class ByteIterator

takeWhile

public final ByteIterator.MultiByteArrayIterator takeWhile(scala.Function1<Object,Object> p)

Specified by:

takeWhile in interface scala.collection.IterableOnceOps<Object,scala.collection.Iterator,scala.collection.Iterator<Object>>

Specified by:

takeWhile in interface scala.collection.Iterator<Object>

Overrides:

takeWhile in class ByteIterator

dropWhile

public final ByteIterator.MultiByteArrayIterator dropWhile(scala.Function1<Object,Object> p)

Specified by:

dropWhile in interface scala.collection.IterableOnceOps<Object,scala.collection.Iterator,scala.collection.Iterator<Object>>

Specified by:

dropWhile in interface scala.collection.Iterator<Object>

Overrides:

dropWhile in class ByteIterator

copyToArray

public final <B> int copyToArray(Object xs,
 int start,
 int len)

foreach

public <U> void foreach(scala.Function1<Object,U> f)

Specified by:

foreach in interface scala.collection.IterableOnceOps<Object,scala.collection.Iterator,scala.collection.Iterator<Object>>

Overrides:

foreach in class ByteIterator

toByteString

public final ByteString toByteString()

Specified by:

toByteString in class ByteIterator

getToArray

protected final <A>
ByteIterator.MultiByteArrayIterator getToArray(Object xs,
 int offset,
 int n,
 int elemSize,
 scala.Function0<A> getSingle,
 scala.Function3<Object,Object,Object,scala.runtime.BoxedUnit> getMult)

getBytes

public ByteIterator.MultiByteArrayIterator getBytes(byte[] xs,
 int offset,
 int n)

Description copied from class: ByteIterator

Get a specific number of Bytes from this iterator. In contrast to copyToArray, this method will fail if length < n or if (xs.length - offset) < n.

Specified by:

getBytes in class ByteIterator

getShorts

public ByteIterator.MultiByteArrayIterator getShorts(short[] xs,
 int offset,
 int n,
 ByteOrder byteOrder)

Description copied from class: ByteIterator

Get a number of Shorts from this iterator.

Specified by:

getShorts in class ByteIterator

getInts

public ByteIterator.MultiByteArrayIterator getInts(int[] xs,
 int offset,
 int n,
 ByteOrder byteOrder)

Description copied from class: ByteIterator

Get a number of Ints from this iterator.

Specified by:

getInts in class ByteIterator

getLongs

public ByteIterator.MultiByteArrayIterator getLongs(long[] xs,
 int offset,
 int n,
 ByteOrder byteOrder)

Description copied from class: ByteIterator

Get a number of Longs from this iterator.

Specified by:

getLongs in class ByteIterator

getFloats

public ByteIterator.MultiByteArrayIterator getFloats(float[] xs,
 int offset,
 int n,
 ByteOrder byteOrder)

Description copied from class: ByteIterator

Get a number of Floats from this iterator.

Specified by:

getFloats in class ByteIterator

getDoubles

public ByteIterator.MultiByteArrayIterator getDoubles(double[] xs,
 int offset,
 int n,
 ByteOrder byteOrder)

Description copied from class: ByteIterator

Get a number of Doubles from this iterator.

Specified by:

getDoubles in class ByteIterator

copyToBuffer

public int copyToBuffer(ByteBuffer buffer)

For performance sensitive code, call copyToBuffer() directly on ByteString (it's optimised there)

Specified by:

copyToBuffer in class ByteIterator

asInputStream

public InputStream asInputStream()

Description copied from class: ByteIterator

Directly wraps this ByteIterator in an InputStream without copying. Read and skip operations on the stream will advance the iterator accordingly.

Specified by:

asInputStream in class ByteIterator