Toggle navigation
Home
org.axonframework.domain.DomainEventStream to java.util.List<org.axonframework.domain.DomainEventMessage<?>>
No. of Instances - 29
No. of Commits - 1
No. of Projects - {'AxonFramework'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Cascading Type Change (Similar)
BaseMatcher<DomainEventStream>
to
TypeSafeMatcher<List<DomainEventMessage<?>>>
DomainEventStream
to
List<DomainEventMessage<?>>
Add or Remove Method invocation
description.appendText("DomainEventStream containing")
to
description.appendText("DomainEvents array containing")
counter
to
item.size()
iterator.next()
to
eventStreamDecorator
uncommittedEvents.next().getPayload()
to
uncommittedEvents.get(i).getPayload()
eventStreamDecorators[i].decorateForAppend(aggregateType,aggregate,events)
to
eventStreamDecorators[i].decorateForAppend(aggregate,events)
aggregateType
to
eventStream.size()
uncommittedEvents.next().getPayload()
to
uncommittedEvents.get(0).getPayload()
uncommittedEvents.next().getPayload()
to
uncommittedEvents.get(1).getPayload()
Update Anonymous class
{ private Long previousCount=null; @Override public boolean matches( Object o){ if (previousCount != null) { return previousCount.equals(expectedCount); } long counter=0; if (o instanceof DomainEventStream) { DomainEventStream events=(DomainEventStream)o; while (events.hasNext()) { events.next(); counter++; } } previousCount=counter; return counter == expectedCount; } @Override public void describeTo( Description description){ description.appendText("DomainEventStream containing"); description.appendValue(expectedCount); description.appendText("events"); } }
to
{ @Override protected boolean matchesSafely( List<DomainEventMessage<?>> item){ return item.size() == expectedCount; } @Override public void describeTo( Description description){ description.appendText("DomainEvents array containing"); description.appendValue(expectedCount); description.appendText("events"); } }
Update argument list (Method invocation)
decorateForAppend
to
decorateForAppend
Convert Class instance creation to method invocation
TriggeringEventStream
to
addAndGet
Other
aggregate.getUncommittedEvents()
to
aggregate.getUncommittedEvents()
Cascading Type Change (Different)
SimpleDomainEventStream
to
ArrayList<>
Update Class Instacne Creation
new ConflictResolvingListener(aggregate,asList(unseenEvents))
to
new ConflictResolvingListener(aggregate,unseenEvents)