本文整理了Java中org.assertj.core.api.AbstractIterableAssert.isSameAs()
方法的一些代码示例,展示了AbstractIterableAssert.isSameAs()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AbstractIterableAssert.isSameAs()
方法的具体详情如下:
包路径:org.assertj.core.api.AbstractIterableAssert
类名称: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);
内容来源于网络,如有侵权,请联系作者删除!