hu.akarnokd.reactive4java.util

Class DefaultGroupedObservable<Key,Value>

java.lang.Object

hu.akarnokd.reactive4java.util.DefaultObservable<Value>

hu.akarnokd.reactive4java.util.DefaultGroupedObservable<Key,Value>

Type Parameters:

Key - the type of the key

Value - the value type

All Implemented Interfaces:

BaseObserver, CloseableObservable<Value>, GroupedObservable<Key,Value>, Observable<Value>, Observer<Value>, Subject<Value,Value>, java.io.Closeable, java.lang.AutoCloseable

public class DefaultGroupedObservable<Key,Value>
extends DefaultObservable<Value>
implements GroupedObservable<Key,Value>

A variant of the registering observable which stores a group key.

Constructor Summary

Constructors

Constructor and Description
DefaultGroupedObservable(Key key) Constructor.

Method Summary

Modifier and Type	Method and Description
Key	key()

Methods inherited from class hu.akarnokd.reactive4java.util.DefaultObservable

close, error, finish, getObserverCount, next, register, unregister

Methods inherited from class java.lang.Object

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

Methods inherited from interface hu.akarnokd.reactive4java.base.Observable

register

Constructor Detail

DefaultGroupedObservable

public DefaultGroupedObservable(Key key)

Constructor.

Parameters:

key - the group key

Method Detail

key

public Key key()

Specified by:

key in interface GroupedObservable<Key,Value>

Returns:

the key of this group.