Package org.springframework.data.redis.connection.stream

Class StreamInfo.XInfoConsumers

java.lang.Object

org.springframework.data.redis.connection.stream.StreamInfo.XInfoConsumers

All Implemented Interfaces:

Iterable<StreamInfo.XInfoConsumer>, Supplier<Stream<StreamInfo.XInfoConsumer>>, org.springframework.data.util.Streamable<StreamInfo.XInfoConsumer>

Enclosing class:

StreamInfo

public static class StreamInfo.XInfoConsumers
extends Object
implements org.springframework.data.util.Streamable<StreamInfo.XInfoConsumer>

Constructor Summary

Constructors

Constructor	Description
XInfoConsumers(String groupName, List<Object> raw)

Method Summary

Modifier and Type	Method	Description
void	forEach(Consumer<? super StreamInfo.XInfoConsumer> action)	Performs the given action on every available StreamInfo.XInfoConsumer of this StreamInfo.XInfoConsumers.
static StreamInfo.XInfoConsumers	fromList(String groupName, List<Object> source)
StreamInfo.XInfoConsumer	get(int index)	Returns the StreamInfo.XInfoConsumer element at the given index.
int	getConsumerCount()	Total number of consumers in the consumer group.
boolean	isEmpty()
Iterator<StreamInfo.XInfoConsumer>	iterator()	Returns an iterator over the StreamInfo.XInfoConsumer elements.
int	size()	Returns the number of StreamInfo.XInfoConsumer available.
Stream<StreamInfo.XInfoConsumer>	stream()	Returns a sequential Stream of StreamInfo.XInfoConsumer.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

spliterator

Methods inherited from interface org.springframework.data.util.Streamable

and, and, and, and, filter, flatMap, get, map, toList, toSet

Constructor Details

XInfoConsumers

public XInfoConsumers(String groupName,
 List<Object> raw)

Method Details

fromList

public static StreamInfo.XInfoConsumers fromList(String groupName,
 List<Object> source)

getConsumerCount

public int getConsumerCount()

Total number of consumers in the consumer group.

Returns:

zero if none available.

size

public int size()

Returns the number of StreamInfo.XInfoConsumer available.

Returns:

zero if none available.

See Also:

• getConsumerCount()

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface org.springframework.data.util.Streamable<StreamInfo.XInfoConsumer>

Returns:

true if no groups associated.

iterator

public Iterator<StreamInfo.XInfoConsumer> iterator()

Returns an iterator over the StreamInfo.XInfoConsumer elements.

Specified by:

iterator in interface Iterable<StreamInfo.XInfoConsumer>

Returns:

get

public StreamInfo.XInfoConsumer get(int index)

Returns the StreamInfo.XInfoConsumer element at the given index.

Returns:

the element at the specified position.

Throws:

IndexOutOfBoundsException - if the index is out of range.

stream

public Stream<StreamInfo.XInfoConsumer> stream()

Returns a sequential Stream of StreamInfo.XInfoConsumer.

Specified by:

stream in interface org.springframework.data.util.Streamable<StreamInfo.XInfoConsumer>

Returns:

forEach

public void forEach(Consumer<? super StreamInfo.XInfoConsumer> action)

Performs the given action on every available StreamInfo.XInfoConsumer of this StreamInfo.XInfoConsumers.

Specified by:

forEach in interface Iterable<StreamInfo.XInfoConsumer>

Parameters:

action -

toString

public String toString()

Overrides:

toString in class Object