org.assertj.core.api.AbstractListAssert.containsSubsequence()方法的使用及代码示例

x33g5p2x  于2022-01-15 转载在 其他  
字(7.2k)|赞(0)|评价(0)|浏览(71)

本文整理了Java中org.assertj.core.api.AbstractListAssert.containsSubsequence()方法的一些代码示例,展示了AbstractListAssert.containsSubsequence()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AbstractListAssert.containsSubsequence()方法的具体详情如下:
包路径:org.assertj.core.api.AbstractListAssert
类名称:AbstractListAssert
方法名:containsSubsequence

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),

相关文章

微信公众号

最新文章

更多