Reject a specific future, or all futures if messageHash is null.
(Object error, Object messageHash2)
| 208 | * Reject a specific future, or all futures if messageHash is null. |
| 209 | */ |
| 210 | public void reject(Object error, Object messageHash2) { |
| 211 | if (messageHash2 != null) { |
| 212 | String messageHash = messageHash2.toString(); |
| 213 | Future f = futuresMap().remove(messageHash); |
| 214 | if (f != null) { |
| 215 | f.reject(error); |
| 216 | } else { |
| 217 | rejectionsMap().put(messageHash, error); |
| 218 | } |
| 219 | } else { |
| 220 | // Reject all pending futures — snapshot keys to avoid ConcurrentModificationException. |
| 221 | var snapshot = new java.util.ArrayList<>(futuresMap().keySet()); |
| 222 | for (String key : snapshot) { |
| 223 | Future f = futuresMap().remove(key); |
| 224 | if (f != null) { |
| 225 | f.reject(error); |
| 226 | } |
| 227 | } |
| 228 | } |
| 229 | } |
| 230 | |
| 231 | public void reject(Object error) { |
| 232 | reject(error, (Object) null); |