Toggle navigation
Home
org.axonframework.queryhandling.FluxSinkWrapper to java.util.concurrent.CopyOnWriteArrayList
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'AxonFramework'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Wrap or Un-wrap
forEach
to
forEach
Add or Remove Method invocation
updateHandlers.remove(query).complete()
to
updateHandlers.remove(query).forEach(FluxSinkWrapper::complete)
updateHandlers.remove(query).error(cause)
to
updateHandlers.remove(query).forEach(uh -> uh.error(cause))