public class BatchAction<T> extends Action<T>
| Modifier and Type | Field and Description |
|---|---|
protected java.util.concurrent.locks.ReentrantLock |
lock |
| Constructor and Description |
|---|
BatchAction(int batchSize,
Observable d,
java.lang.Object successKey,
java.lang.Object failureKey) |
BatchAction(int batchSize,
Observable d,
java.lang.Object successKey,
java.lang.Object failureKey,
java.lang.Object flushKey,
java.lang.Object firstKey) |
| Modifier and Type | Method and Description |
|---|---|
void |
doAccept(Event<T> value) |
protected void |
doFirst(Event<T> event) |
protected void |
doFlush(Event<T> event) |
protected void |
doNext(Event<T> event) |
long |
getAcceptCount() |
int |
getBatchSize() |
long |
getErrorCount() |
java.lang.Object |
getFirstKey() |
java.lang.Object |
getFlushKey() |
protected void |
notifyError(java.lang.Throwable error)
Notify this
Composable that an error is being propagated through this Observable. |
java.lang.String |
toString() |
accept, getFailureKey, getObservable, getSuccessKey, notifyValuepublic BatchAction(int batchSize,
Observable d,
java.lang.Object successKey,
java.lang.Object failureKey)
public BatchAction(int batchSize,
Observable d,
java.lang.Object successKey,
java.lang.Object failureKey,
java.lang.Object flushKey,
java.lang.Object firstKey)
public java.lang.Object getFlushKey()
public java.lang.Object getFirstKey()
public long getErrorCount()
public long getAcceptCount()
public int getBatchSize()
protected void notifyError(java.lang.Throwable error)
ActionComposable that an error is being propagated through this Observable.notifyError in class Action<T>error - the error to propagate