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

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

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

AbstractIterableAssert.containsOnly介绍

暂无

代码示例

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

/**
 * {@inheritDoc}
 */
@Override
public SELF containsOnlyElementsOf(Iterable<? extends ELEMENT> iterable) {
 return containsOnly(toArray(iterable));
}

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

/**
 * {@inheritDoc}
 */
@Override
public SELF containsOnlyElementsOf(Iterable<? extends ELEMENT> iterable) {
 return containsOnly(toArray(iterable));
}

代码示例来源：origin: square/assertj-android

public MultiSelectListPreferenceAssert hasValues(String... values) {
  isNotNull();
  Set<String> actualValues = actual.getValues();
  assertThat(actualValues) //
    .overridingErrorMessage("Expected values <%s> but was <%s>.", values, actualValues) //
    .containsOnly(values);
  return this;
 }
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void execute_populate_tmp_last_key_columns_from_type_and_component_uuid_columns() throws SQLException {
 String type = randomAlphabetic(6);
 String oldComponentUuid = randomAlphabetic(7);
 String tmpComponentUuid = randomAlphabetic(8);
 String tmpMainComponentUuid = randomAlphabetic(9);
 String taskWithComponentUuid = insertCeActivity(type, oldComponentUuid, tmpComponentUuid, tmpMainComponentUuid);
 String taskWithInconsistentComponentUuid = insertCeActivity(type, null, tmpComponentUuid, tmpMainComponentUuid);
 String taskNoComponentUuid = insertCeActivity(type, null, null, null);
 underTest.execute();
 assertThatTmpLastKeyAndMainLastKeyOf(taskWithComponentUuid).containsOnly(tuple(type + tmpComponentUuid, type + tmpMainComponentUuid));
 assertThatTmpLastKeyAndMainLastKeyOf(taskWithInconsistentComponentUuid).containsOnly(tuple(type, type));
 assertThatTmpLastKeyAndMainLastKeyOf(taskNoComponentUuid).containsOnly(tuple(type, type));
 assertThatTmpIsLastAndMainIsLastOf(taskWithComponentUuid).containsOnly(tuple(false, false));
 assertThatTmpIsLastAndMainIsLastOf(taskWithInconsistentComponentUuid).containsOnly(tuple(false, false));
 assertThatTmpIsLastAndMainIsLastOf(taskNoComponentUuid).containsOnly(tuple(false, false));
}
@Test

代码示例来源：origin: facebook/litho

assertThat(content.getDispatchedEventHandlers()).containsOnly(focusedHandler);
assertThat(content.getDispatchedEventHandlers()).containsOnly(unfocusedHandler);
assertThat(content.getDispatchedEventHandlers()).containsOnly(focusedHandler);
assertThat(content.getDispatchedEventHandlers()).containsOnly(unfocusedHandler);

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Test(groups = "unit")
public void should_filter_init_hosts_with_predicate() {
 Predicate<Host> predicate = Predicates.in(Lists.newArrayList(host1, host2));
 HostFilterPolicy policy = new HostFilterPolicy(wrappedPolicy, predicate);
 policy.init(cluster, Lists.newArrayList(host1, host2, host3));
 verify(wrappedPolicy).init(eq(cluster), hostsCaptor.capture());
 assertThat(hostsCaptor.getValue()).containsOnly(host1, host2);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Test(groups = "short")
public void should_delete_set_element() throws Exception {
 // given
 session().execute("INSERT INTO test_coll (k, c) VALUES (1, {'foo','bar','qix'})");
 // when
 BuiltStatement statement = delete().setElt("c", "foo").from("test_coll").where(eq("k", 1));
 session().execute(statement);
 // then
 Set<String> actual =
   session().execute("SELECT c FROM test_coll WHERE k = 1").one().getSet("c", String.class);
 assertThat(actual).containsOnly("bar", "qix");
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Test(groups = "short", dataProvider = "serverSideErrors")
public void should_try_next_host_on_server_side_error(
  Result error, Class<? extends DriverException> exception) {
 simulateError(1, error);
 simulateError(2, error);
 simulateError(3, error);
 try {
  query();
  Fail.fail("expected a NoHostAvailableException");
 } catch (NoHostAvailableException e) {
  assertThat(e.getErrors().keySet())
    .hasSize(3)
    .containsOnly(
      host1.getSocketAddress(), host2.getSocketAddress(), host3.getSocketAddress());
  assertThat(e.getErrors().values()).hasOnlyElementsOfType(exception);
 }
 assertOnRequestErrorWasCalled(3, exception);
 assertThat(errors.getOthers().getCount()).isEqualTo(3);
 assertThat(errors.getRetries().getCount()).isEqualTo(3);
 assertThat(errors.getRetriesOnOtherErrors().getCount()).isEqualTo(3);
 assertQueried(1, 1);
 assertQueried(2, 1);
 assertQueried(3, 1);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Test(groups = "short", dataProvider = "connectionErrors")
public void should_try_next_host_on_connection_error(ClosedConnectionConfig.CloseType closeType) {
 simulateError(1, closed_connection, new ClosedConnectionConfig(closeType));
 simulateError(2, closed_connection, new ClosedConnectionConfig(closeType));
 simulateError(3, closed_connection, new ClosedConnectionConfig(closeType));
 try {
  query();
  Fail.fail("expected a NoHostAvailableException");
 } catch (NoHostAvailableException e) {
  assertThat(e.getErrors().keySet())
    .hasSize(3)
    .containsOnly(
      host1.getSocketAddress(), host2.getSocketAddress(), host3.getSocketAddress());
  assertThat(e.getErrors().values()).hasOnlyElementsOfType(TransportException.class);
 }
 assertOnRequestErrorWasCalled(3, TransportException.class);
 assertThat(errors.getRetries().getCount()).isEqualTo(3);
 assertThat(errors.getConnectionErrors().getCount()).isEqualTo(3);
 assertThat(errors.getIgnoresOnConnectionError().getCount()).isEqualTo(0);
 assertThat(errors.getRetriesOnConnectionError().getCount()).isEqualTo(3);
 assertQueried(1, 1);
 assertQueried(2, 1);
 assertQueried(3, 1);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Test(groups = "short", dataProvider = "connectionErrors")
public void should_retry_on_connection_error_if_statement_idempotent(
  ClosedConnectionConfig.CloseType closeType) {
 simulateError(1, closed_connection, new ClosedConnectionConfig(closeType));
 simulateError(2, closed_connection, new ClosedConnectionConfig(closeType));
 simulateError(3, closed_connection, new ClosedConnectionConfig(closeType));
 try {
  session.execute(new SimpleStatement("mock query").setIdempotent(true));
  Fail.fail("expected a TransportException");
 } catch (NoHostAvailableException e) {
  assertThat(e.getErrors().keySet())
    .hasSize(3)
    .containsOnly(
      host1.getSocketAddress(), host2.getSocketAddress(), host3.getSocketAddress());
  assertThat(e.getErrors().values()).hasOnlyElementsOfType(TransportException.class);
 }
 assertOnRequestErrorWasCalled(3, TransportException.class);
 assertThat(errors.getRetries().getCount()).isEqualTo(3);
 assertThat(errors.getConnectionErrors().getCount()).isEqualTo(3);
 assertThat(errors.getIgnoresOnConnectionError().getCount()).isEqualTo(0);
 assertThat(errors.getRetriesOnConnectionError().getCount()).isEqualTo(3);
 assertQueried(1, 1);
 assertQueried(2, 1);
 assertQueried(3, 1);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@SuppressWarnings("UnusedParameters")
@Test(groups = "short", dataProvider = "serverSideErrors")
public void should_retry_on_server_error_if_statement_idempotent(
  Result error, Class<? extends DriverException> exception) {
 simulateError(1, error);
 simulateError(2, error);
 simulateError(3, error);
 try {
  session.execute(new SimpleStatement("mock query").setIdempotent(true));
  fail("expected a NoHostAvailableException");
 } catch (NoHostAvailableException e) {
  assertThat(e.getErrors().keySet())
    .hasSize(3)
    .containsOnly(
      host1.getSocketAddress(), host2.getSocketAddress(), host3.getSocketAddress());
  assertThat(e.getErrors().values()).hasOnlyElementsOfType(exception);
 }
 assertOnRequestErrorWasCalled(3, exception);
 assertThat(errors.getOthers().getCount()).isEqualTo(3);
 assertThat(errors.getRetries().getCount()).isEqualTo(3);
 assertThat(errors.getRetriesOnOtherErrors().getCount()).isEqualTo(3);
 assertQueried(1, 1);
 assertQueried(2, 1);
 assertQueried(3, 1);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

/**
 * Ensures that when handling a connection error caused by the connection closing during a request
 * in a way described by {@link #connectionErrors} that the next host is tried.
 *
 * @param closeType The way the connection should be closed during the request.
 */
@Test(groups = "short", dataProvider = "connectionErrors")
public void should_try_next_host_on_connection_error(ClosedConnectionConfig.CloseType closeType) {
 simulateError(1, closed_connection, new ClosedConnectionConfig(closeType));
 simulateError(2, closed_connection, new ClosedConnectionConfig(closeType));
 simulateError(3, closed_connection, new ClosedConnectionConfig(closeType));
 try {
  query();
  Fail.fail("expected a TransportException");
 } catch (NoHostAvailableException e) {
  assertThat(e.getErrors().keySet())
    .hasSize(3)
    .containsOnly(
      host1.getSocketAddress(), host2.getSocketAddress(), host3.getSocketAddress());
  assertThat(e.getErrors().values()).hasOnlyElementsOfType(TransportException.class);
 }
 assertOnRequestErrorWasCalled(3, TransportException.class);
 assertThat(errors.getRetries().getCount()).isEqualTo(3);
 assertThat(errors.getConnectionErrors().getCount()).isEqualTo(3);
 assertThat(errors.getIgnoresOnConnectionError().getCount()).isEqualTo(0);
 assertThat(errors.getRetriesOnConnectionError().getCount()).isEqualTo(3);
 assertQueried(1, 1);
 assertQueried(2, 1);
 assertQueried(3, 1);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

assertThat(e.getErrors().keySet())
  .hasSize(3)
  .containsOnly(
    host1.getSocketAddress(), host2.getSocketAddress(), host3.getSocketAddress());
assertThat(e.getErrors().values()).hasOnlyElementsOfType(exception);

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Test(groups = "short")
public void should_delete_set_element_with_bind_marker() throws Exception {
 // given
 session().execute("INSERT INTO test_coll (k, c) VALUES (1, {'foo','bar','qix'})");
 // when
 BuiltStatement statement =
   delete().setElt("c", bindMarker()).from("test_coll").where(eq("k", 1));
 PreparedStatement ps = session().prepare(statement);
 session().execute(ps.bind("foo"));
 // then
 Set<String> actual =
   session().execute("SELECT c FROM test_coll WHERE k = 1").one().getSet("c", String.class);
 assertThat(actual).containsOnly("bar", "qix");
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

/** JAVA-684: Empty TokenRange returned in a one token cluster */
 @Test(groups = "short")
 public void should_return_single_non_empty_range_when_cluster_has_one_single_token() {
  cluster().manager.controlConnection.refreshNodeListAndTokenMap();
  Metadata metadata = cluster().getMetadata();
  Set<TokenRange> tokenRanges = metadata.getTokenRanges();
  assertThat(tokenRanges).hasSize(1);
  TokenRange tokenRange = tokenRanges.iterator().next();
  assertThat(tokenRange)
    .startsWith(Token.M3PToken.FACTORY.minToken())
    .endsWith(Token.M3PToken.FACTORY.minToken())
    .isNotEmpty()
    .isNotWrappedAround();

  Set<Host> hostsForRange = metadata.getReplicas(keyspace, tokenRange);
  Host host1 = TestUtils.findHost(cluster(), 1);
  assertThat(hostsForRange).containsOnly(host1);

  ByteBuffer randomPartitionKey = Bytes.fromHexString("0xCAFEBABE");
  Set<Host> hostsForKey = metadata.getReplicas(keyspace, randomPartitionKey);
  assertThat(hostsForKey).containsOnly(host1);

  Set<TokenRange> rangesForHost = metadata.getTokenRanges(keyspace, host1);
  assertThat(rangesForHost).containsOnly(tokenRange);
 }
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

assertThat(initHostsCaptor.getValue()).containsOnly(host1, host3);

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

assertThat(initHostsCaptor.getValue()).containsOnly(host1, host3);

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

assertThat(initHostsCaptor.getValue()).containsOnly(host1);

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

assertThat(e.getErrors().keySet())
  .hasSize(3)
  .containsOnly(
    host1.getSocketAddress(), host2.getSocketAddress(), host3.getSocketAddress());
assertThat(e.getErrors().values())

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

queryCounts.add(queryTracker.queryCount(sCluster, 2, i));
 assertThat(queryCounts).containsOnly(0, 0, 0, 25, 25);
} finally {
 cluster.close();

内容来源于网络，如有侵权，请联系作者删除！

AbstractIterableAssert

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    AbstractIterableAssert类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com