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

Class StreamInfo.XInfoConsumers

java.lang.Object

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

Enclosing class:

StreamInfo

public static class StreamInfo.XInfoConsumers
extends Object

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

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()

Returns:

true if no groups associated.

iterator

public Iterator<StreamInfo.XInfoConsumer> iterator()

Returns an iterator over the StreamInfo.XInfoConsumer elements.

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.

Returns:

forEach

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

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

Parameters:

action -

toString

public String toString()

Overrides:

toString in class Object