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

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

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

AbstractIterableAssert.isSameAs介绍

暂无

代码示例

代码示例来源:origin: org.assertj/assertj-core

@Override
public SELF isSameAs(Object expected) {
 return super.isSameAs(expected);
}

代码示例来源:origin: joel-costigliola/assertj-core

@Override
public SELF isSameAs(Object expected) {
 return super.isSameAs(expected);
}

代码示例来源:origin: json-path/JsonPath

@Test
public void always_return_same_object() { // Test because of Bug #211
  DocumentContext context = using(JACKSON_JSON_NODE_CONFIGURATION).parse(JSON_DOCUMENT);
  ObjectNode node1 = context.read("$");
  ObjectNode child1 = new ObjectNode(JsonNodeFactory.instance);
  child1.put("name", "test");
  context.put("$", "child", child1);
  ObjectNode node2 = context.read("$");
  ObjectNode child2 = context.read("$.child");
  assertThat(node1).isSameAs(node2);
  assertThat(child1).isSameAs(child2);
}

代码示例来源:origin: Nike-Inc/wingtips

@Test
public void constructor_sets_fields_as_expected() {
  // when
  TracingState tracingState = new TracingState(spanStackMock, mdcInfoMock);
  // then
  assertThat(tracingState.spanStack).isSameAs(spanStackMock);
  assertThat(tracingState.mdcInfo).isSameAs(mdcInfoMock);
}

代码示例来源:origin: Nike-Inc/wingtips

@DataProvider(value = {
  "true",
  "false"
}, splitBy = "\\|")
@Test
public void convenience_constructor_sets_fields_and_kicks_off_scheduled_job_as_expected(boolean compressPayloadOpt) throws MalformedURLException {
  // given
  String baseUrl = "http://localhost:4242";
  final ScheduledExecutorService schedulerMock = mock(ScheduledExecutorService.class);
  // when
  ZipkinSpanSenderDefaultHttpImpl impl = new ZipkinSpanSenderDefaultHttpImpl(baseUrl, compressPayloadOpt) {
    @Override
    protected ScheduledExecutorService configureScheduledExecutorServiceForBatching() {
      return schedulerMock;
    }
  };
  // then
  assertThat(impl.postZipkinSpansUrl).isEqualTo(new URL(baseUrl + "/api/v1/spans"));
  assertThat(impl.compressZipkinSpanPayload).isEqualTo(compressPayloadOpt);
  assertThat(impl.connectTimeoutMillis).isEqualTo(ZipkinSpanSenderDefaultHttpImpl.DEFAULT_CONNECT_TIMEOUT_MILLIS);
  assertThat(impl.readTimeoutMillis).isEqualTo(ZipkinSpanSenderDefaultHttpImpl.DEFAULT_READ_TIMEOUT_MILLIS);
  assertThat(impl.senderJob).isNotNull();
  assertThat(impl.senderJob.zipkinSpanSender).isSameAs(impl);
  assertThat(impl.senderJob.zipkinSpanSendingQueue).isSameAs(impl.zipkinSpanSendingQueue);
  verify(schedulerMock).scheduleAtFixedRate(impl.senderJob,
                       ZipkinSpanSenderDefaultHttpImpl.DEFAULT_SPAN_BATCH_SENDING_PERIOD_MILLIS,
                       ZipkinSpanSenderDefaultHttpImpl.DEFAULT_SPAN_BATCH_SENDING_PERIOD_MILLIS,
                       TimeUnit.MILLISECONDS);
}

代码示例来源:origin: Nike-Inc/wingtips

@Test
public void pair_methods_work_as_expected() {
  // expect
  assertThat(tracingState.getLeft()).isSameAs(spanStackMock);
  assertThat(tracingState.getKey()).isSameAs(spanStackMock);
  assertThat(tracingState.getRight()).isSameAs(mdcInfoMock);
  assertThat(tracingState.getValue()).isSameAs(mdcInfoMock);
}

代码示例来源:origin: Nike-Inc/wingtips

assertThat(impl.senderJob.zipkinSpanSendingQueue).isSameAs(impl.zipkinSpanSendingQueue);

代码示例来源:origin: Nike-Inc/riposte

@Test
public void constructor_sets_fields_based_on_incoming_args() {
  // when
  RoutingHandler theHandler = new RoutingHandler(endpoints, maxRequestSizeInBytes);
  // then
  Collection<Endpoint<?>>
    actualEndpoints = (Collection<Endpoint<?>>) Whitebox.getInternalState(theHandler, "endpoints");
  assertThat(actualEndpoints).isSameAs(endpoints);
}

代码示例来源:origin: Nike-Inc/wingtips

@Test
@UseDataProvider("spanStackDataProvider")
public void starting_a_request_should_reset_span_stack_no_matter_what_the_span_stack_already_looked_like(Deque<Span> stackToUse) {
  // given
  getSpanStackThreadLocal().set(stackToUse);
  assertThat(getSpanStackFromTracer()).isSameAs(stackToUse);
  String newRequestSpanName = UUID.randomUUID().toString();
  // when
  Span newRequestSpan = Tracer.getInstance().startRequestWithRootSpan(newRequestSpanName);
  // then
  assertThat(getSpanStackFromTracer()).isNotSameAs(stackToUse);
  assertThat(getSpanStackSize()).isEqualTo(1);
  assertThat(Tracer.getInstance().getCurrentSpan()).isEqualTo(newRequestSpan);
  assertThat(Tracer.getInstance().getCurrentSpan().getSpanName()).isEqualTo(newRequestSpanName);
}

代码示例来源:origin: Nike-Inc/riposte

@Test
public void StreamingChannel_constructor_sets_fields_as_expected() {
  // given
  Deque<Span> spanStackMock = mock(Deque.class);
  Map<String, String> mdcInfoMock = mock(Map.class);
  // when
  StreamingChannel sc = new StreamingChannel(
    channelMock, channelPoolMock, callActiveHolder, downstreamLastChunkSentHolder, spanStackMock, mdcInfoMock,
    spanForDownstreamCallMock, proxySpanTaggingStrategyMock
  );
  // then
  assertThat(sc.channel).isSameAs(channelMock);
  assertThat(sc.getChannel()).isSameAs(sc.channel);
  assertThat(sc.pool).isSameAs(channelPoolMock);
  assertThat(sc.callActiveHolder).isSameAs(callActiveHolder);
  assertThat(sc.downstreamLastChunkSentHolder).isSameAs(downstreamLastChunkSentHolder);
  assertThat(sc.distributedTracingSpanStack).isSameAs(spanStackMock);
  assertThat(sc.distributedTracingMdcInfo).isSameAs(mdcInfoMock);
  assertThat(sc.spanForDownstreamCall).isSameAs(spanForDownstreamCallMock);
  assertThat(sc.proxySpanTaggingStrategy).isSameAs(proxySpanTaggingStrategyMock);
}

代码示例来源:origin: Nike-Inc/riposte

@Test
public void constructor_sets_values_exactly_as_given_when_subtracing_is_off() {
  // given
  CompletableFuture cfResponse = mock(CompletableFuture.class);
  AsyncResponseHandler responseHandlerFunc = mock(AsyncResponseHandler.class);
  RequestBuilderWrapper rbwMock = mock(RequestBuilderWrapper.class);
  Optional<CircuitBreaker<Response>> circuitBreaker = Optional.of(mock(CircuitBreaker.class));
  Deque<Span> spanStack = mock(Deque.class);
  Map<String, String> mdcInfo = mock(Map.class);
  Deque<Span> spanStackBeforeCall = Tracer.getInstance().getCurrentSpanStackCopy();
  Map<String, String> mdcInfoBeforeCall = MDC.getCopyOfContextMap();
  // when
  AsyncCompletionHandlerWithTracingAndMdcSupport instance = new AsyncCompletionHandlerWithTracingAndMdcSupport(
    cfResponse, responseHandlerFunc, false, rbwMock, circuitBreaker, spanStack, mdcInfo,
    tagAndNamingStrategy
  );
  // then
  assertThat(instance.completableFutureResponse).isSameAs(cfResponse);
  assertThat(instance.responseHandlerFunction).isSameAs(responseHandlerFunc);
  assertThat(instance.performSubSpanAroundDownstreamCalls).isEqualTo(false);
  assertThat(instance.circuitBreakerManualTask).isSameAs(circuitBreaker);
  assertThat(instance.distributedTraceStackToUse).isSameAs(spanStack);
  assertThat(instance.mdcContextToUse).isSameAs(mdcInfo);
  assertThat(Tracer.getInstance().getCurrentSpanStackCopy()).isEqualTo(spanStackBeforeCall);
  assertThat(MDC.getCopyOfContextMap()).isEqualTo(mdcInfoBeforeCall);
}

代码示例来源:origin: Nike-Inc/riposte

assertThat(achwtams.distributedTraceStackToUse).isSameAs(initialSpanStack);
assertThat(achwtams.mdcContextToUse).isSameAs(initialMdc);

相关文章

微信公众号

最新文章

更多