public static class ForwardingBox.RxLock<T> extends ForwardingBox<T,RxLockBox<T>> implements RxLockBox<T>
ForwardingBox.Cas<T>, ForwardingBox.Lock<T>, ForwardingBox.Rx<T>, ForwardingBox.RxLock<T>
delegate
Modifier | Constructor and Description |
---|---|
protected |
RxLock(RxLockBox<T> delegate) |
Modifier and Type | Method and Description |
---|---|
Observable<T> |
asObservable() |
Object |
lock()
The lock which is used by this LockBox's
method . |
get, set
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
modify, transactOn
combineLatest, from, fromVolatile, map
subscribe, wrap
accept, from, ofVolatile, set
public Object lock()
LockBox
method
.
For a LockBox which holds state, the LockBox itself is used. For a mapped
LockBox, the underlying LockBox which actually holds the state is used.public Observable<T> asObservable()
asObservable
in interface IObservable<T>