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

Class StreamInfo.XInfoGroups

java.lang.Object

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

All Implemented Interfaces:

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

Enclosing class:

StreamInfo

public static class StreamInfo.XInfoGroups
extends Object
implements org.springframework.data.util.Streamable<StreamInfo.XInfoGroup>

Value object holding general information about consumer groups associated with a Redis Stream.

Author:

Christoph Strobl

Method Summary

Modifier and Type	Method	Description
void	forEach(Consumer<? super StreamInfo.XInfoGroup> action)	Performs the given action on every available StreamInfo.XInfoGroup of this StreamInfo.XInfoGroups.
static StreamInfo.XInfoGroups	fromList(List<Object> source)	Factory method to create a new instance of StreamInfo.XInfoGroups.
StreamInfo.XInfoGroup	get(int index)	Returns the StreamInfo.XInfoGroup element at the given index.
int	groupCount()	Total number of associated consumer groups.
boolean	isEmpty()
Iterator<StreamInfo.XInfoGroup>	iterator()	Returns an iterator over the StreamInfo.XInfoGroup elements.
int	size()	Returns the number of StreamInfo.XInfoGroup available.
Stream<StreamInfo.XInfoGroup>	stream()	Returns a sequential Stream of StreamInfo.XInfoGroup.
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

Method Details

fromList

public static StreamInfo.XInfoGroups fromList(List<Object> source)

Factory method to create a new instance of StreamInfo.XInfoGroups.

Parameters:

source - the raw value source.

Returns:

groupCount

public int groupCount()

Total number of associated consumer groups.

Returns:

zero if none available.

size

public int size()

Returns the number of StreamInfo.XInfoGroup available.

Returns:

zero if none available.

See Also:

• groupCount()

isEmpty

public boolean isEmpty()

Specified by:

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

Returns:

true if no groups associated.

iterator

public Iterator<StreamInfo.XInfoGroup> iterator()

Returns an iterator over the StreamInfo.XInfoGroup elements.

Specified by:

iterator in interface Iterable<StreamInfo.XInfoGroup>

Returns:

get

public StreamInfo.XInfoGroup get(int index)

Returns the StreamInfo.XInfoGroup 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.XInfoGroup> stream()

Returns a sequential Stream of StreamInfo.XInfoGroup.

Specified by:

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

Returns:

forEach

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

Performs the given action on every available StreamInfo.XInfoGroup of this StreamInfo.XInfoGroups.

Specified by:

forEach in interface Iterable<StreamInfo.XInfoGroup>

Parameters:

action -

toString

public String toString()

Overrides:

toString in class Object