本文整理了Java中org.assertj.core.api.AbstractListAssert.containsSubsequence()
方法的一些代码示例,展示了AbstractListAssert.containsSubsequence()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AbstractListAssert.containsSubsequence()
方法的具体详情如下:
包路径:org.assertj.core.api.AbstractListAssert
类名称:AbstractListAssert
方法名:containsSubsequence
暂无
代码示例来源:origin: spring-projects/spring-security
@Test
public void configureWhenCustomFiltersThenAddedToChainInCorrectOrder() {
System.setProperty("customFilterRef", "userFilter");
this.spring.configLocations(xml("CustomFilters")).autowire();
List<Filter> filters = getFilters("/");
Class<?> userFilterClass = this.spring.getContext().getBean("userFilter").getClass();
assertThat(filters)
.extracting((Extractor<Filter, Class<?>>) filter -> filter.getClass())
.containsSubsequence(
userFilterClass, userFilterClass,
SecurityContextPersistenceFilter.class, LogoutFilter.class,
userFilterClass);
}
代码示例来源:origin: spring-projects/spring-security
@Test
public void configureWhenUsingX509ThenAddsX509FilterCorrectly() {
this.spring.configLocations(xml("X509")).autowire();
assertThat(getFilters("/"))
.extracting((Extractor<Filter, Class<?>>) filter -> filter.getClass())
.containsSubsequence(
CsrfFilter.class, X509AuthenticationFilter.class, ExceptionTranslationFilter.class);
}
代码示例来源:origin: io.zeebe/zeebe-broker-core
@Test
public void shouldMergeParallelBranches() {
// given
testClient.deploy(FORK_JOIN_PROCESS);
// when
testClient.createWorkflowInstance(PROCESS_ID);
// then
final List<Record<WorkflowInstanceRecordValue>> events =
testClient
.receiveWorkflowInstances()
.limitToWorkflowInstanceCompleted()
.collect(Collectors.toList());
assertThat(events)
.extracting(e -> e.getValue().getElementId(), e -> e.getMetadata().getIntent())
.containsSubsequence(
tuple("flow1", WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN),
tuple("join", WorkflowInstanceIntent.ELEMENT_ACTIVATING))
.containsSubsequence(
tuple("flow2", WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN),
tuple("join", WorkflowInstanceIntent.ELEMENT_ACTIVATING))
.containsOnlyOnce(tuple("join", WorkflowInstanceIntent.ELEMENT_ACTIVATING));
}
代码示例来源:origin: zeebe-io/zeebe
@Test
public void shouldMergeParallelBranches() {
// given
testClient.deploy(FORK_JOIN_PROCESS);
// when
final long workflowInstanceKey = testClient.createWorkflowInstance(PROCESS_ID);
// then
final List<Record<WorkflowInstanceRecordValue>> events =
testClient
.receiveWorkflowInstances()
.limit(
r ->
r.getKey() == workflowInstanceKey
&& WorkflowInstanceIntent.ELEMENT_COMPLETED == r.getMetadata().getIntent())
.collect(Collectors.toList());
assertThat(events)
.extracting(e -> e.getValue().getElementId(), e -> e.getMetadata().getIntent())
.containsSubsequence(
tuple("flow1", WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN),
tuple("join", WorkflowInstanceIntent.GATEWAY_ACTIVATED))
.containsSubsequence(
tuple("flow2", WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN),
tuple("join", WorkflowInstanceIntent.GATEWAY_ACTIVATED))
.containsOnlyOnce(tuple("join", WorkflowInstanceIntent.GATEWAY_ACTIVATED));
}
代码示例来源:origin: zeebe-io/zeebe
.extracting(Record::getMetadata)
.extracting(RecordMetadata::getRecordType, RecordMetadata::getIntent)
.containsSubsequence(
tuple(RecordType.COMMAND, IncidentIntent.RESOLVE),
tuple(RecordType.EVENT, IncidentIntent.RESOLVED));
.extracting(Record::getMetadata)
.extracting(RecordMetadata::getIntent)
.containsSubsequence(
WorkflowInstanceIntent.GATEWAY_ACTIVATED,
WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN,
代码示例来源:origin: io.zeebe/zeebe-broker-core
.extracting(Record::getMetadata)
.extracting(RecordMetadata::getRecordType, RecordMetadata::getIntent)
.containsSubsequence(
tuple(RecordType.COMMAND, IncidentIntent.RESOLVE),
tuple(RecordType.EVENT, IncidentIntent.RESOLVED));
.extracting(Record::getMetadata)
.extracting(RecordMetadata::getIntent)
.containsSubsequence(
WorkflowInstanceIntent.ELEMENT_ACTIVATED,
WorkflowInstanceIntent.ELEMENT_COMPLETING,
代码示例来源:origin: zeebe-io/zeebe
@Test
public void shouldCompleteScopeWithMultipleTokensOnSamePath() {
// given
final BpmnModelInstance process =
Bpmn.createExecutableProcess(PROCESS_ID)
.startEvent()
.parallelGateway("fork")
.exclusiveGateway("join")
.endEvent("end")
.moveToNode("fork")
.connectTo("join")
.done();
testClient.deploy(process);
// when
testClient.createWorkflowInstance(PROCESS_ID);
// then
final List<Record<WorkflowInstanceRecordValue>> workflowInstanceEvents =
testClient
.receiveWorkflowInstances()
.limitToWorkflowInstanceCompleted()
.collect(Collectors.toList());
assertThat(workflowInstanceEvents)
.extracting(e -> e.getValue().getElementId(), e -> e.getMetadata().getIntent())
.containsSubsequence(
tuple("end", WorkflowInstanceIntent.EVENT_ACTIVATED),
tuple("end", WorkflowInstanceIntent.EVENT_ACTIVATED),
tuple(PROCESS_ID, WorkflowInstanceIntent.ELEMENT_COMPLETED));
}
代码示例来源:origin: io.zeebe/zeebe-broker-core
@Test
public void shouldCompleteScopeWithMultipleTokensOnSamePath() {
// given
final BpmnModelInstance process =
Bpmn.createExecutableProcess(PROCESS_ID)
.startEvent()
.parallelGateway("fork")
.exclusiveGateway("join")
.endEvent("end")
.moveToNode("fork")
.connectTo("join")
.done();
testClient.deploy(process);
// when
testClient.createWorkflowInstance(PROCESS_ID);
// then
final List<Record<WorkflowInstanceRecordValue>> workflowInstanceEvents =
testClient
.receiveWorkflowInstances()
.limitToWorkflowInstanceCompleted()
.collect(Collectors.toList());
assertThat(workflowInstanceEvents)
.extracting(e -> e.getValue().getElementId(), e -> e.getMetadata().getIntent())
.containsSubsequence(
tuple("end", WorkflowInstanceIntent.ELEMENT_COMPLETED),
tuple("end", WorkflowInstanceIntent.ELEMENT_COMPLETED),
tuple(PROCESS_ID, WorkflowInstanceIntent.ELEMENT_COMPLETED));
}
代码示例来源:origin: io.zeebe/zeebe-broker-core
.extracting(Record::getMetadata)
.extracting(RecordMetadata::getRecordType, RecordMetadata::getIntent)
.containsSubsequence(
tuple(RecordType.COMMAND, IncidentIntent.RESOLVE),
tuple(RecordType.EVENT, IncidentIntent.RESOLVED));
.extracting(Record::getMetadata)
.extracting(RecordMetadata::getIntent)
.containsSubsequence(
WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN,
WorkflowInstanceIntent.ELEMENT_ACTIVATING,
代码示例来源:origin: zeebe-io/zeebe
.extracting(Record::getMetadata)
.extracting(RecordMetadata::getRecordType, RecordMetadata::getIntent)
.containsSubsequence(
tuple(RecordType.COMMAND, IncidentIntent.RESOLVE),
tuple(RecordType.EVENT, IncidentIntent.RESOLVED));
.extracting(Record::getMetadata)
.extracting(RecordMetadata::getIntent)
.containsSubsequence(
WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN,
WorkflowInstanceIntent.EVENT_ACTIVATING,
代码示例来源:origin: zeebe-io/zeebe
.containsSubsequence(
tuple("joinFlow1", WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN),
tuple("joinFlow1", WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN),
代码示例来源:origin: io.zeebe/zeebe-broker-core
.containsSubsequence(
tuple("joinFlow1", WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN),
tuple("joinFlow1", WorkflowInstanceIntent.SEQUENCE_FLOW_TAKEN),
内容来源于网络,如有侵权,请联系作者删除!