io.vavr.collection.Array.of()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(6.9k)|赞(0)|评价(0)|浏览(138)

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

Array.of介绍

[英]Returns a singleton Array, i.e. a Array of one element.
[中]返回一个单例数组,即一个元素的数组。

代码示例

代码示例来源:origin: vavr-io/vavr

/**
 * Alias for {@link Array#of(Object)}
 *
 * @param <T>     Component type of element.
 * @param element An element.
 * @return A new {@link Array} instance containing the given element
 */
public static <T> Array<T> Array(T element) {
  return Array.of(element);
}

代码示例来源:origin: vavr-io/vavr

/**
 * Alias for {@link Array#of(Object...)}
 *
 * @param <T>      Component type of elements.
 * @param elements Zero or more elements.
 * @return A new {@link Array} instance containing the given elements
 * @throws NullPointerException if {@code elements} is null
 */
@SuppressWarnings("varargs")
@SafeVarargs
public static <T> Array<T> Array(T... elements) {
  return Array.of(elements);
}
// -- List

代码示例来源:origin: resilience4j/resilience4j

/**
 * Creates a new instance of {@link RateLimiterMetrics} with a rate limiter as a source.
 *
 * @param rateLimiter the rate limiter
 */
public static RateLimiterMetrics ofRateLimiter(RateLimiter rateLimiter) {
  return new RateLimiterMetrics(Array.of(rateLimiter));
}

代码示例来源:origin: resilience4j/resilience4j

/**
 * Creates a new instance of {@link CircuitBreakerExports} with default metrics names prefix and
 * a circuit breaker as a source.
 *
 * @param prefix the prefix of metrics names
 * @param circuitBreaker the circuit breaker
 */
public static CircuitBreakerExports ofCircuitBreaker(String prefix, CircuitBreaker circuitBreaker) {
  requireNonNull(prefix);
  requireNonNull(circuitBreaker);
  return new CircuitBreakerExports(prefix, Array.of(circuitBreaker));
}

代码示例来源:origin: resilience4j/resilience4j

/**
 * Creates a new instance of BulkheadMetrics {@link BulkheadMetrics} with a bulkhead as a source.
 *
 * @param bulkhead the circuit breaker
 */
public static BulkheadMetrics ofBulkhead(Bulkhead bulkhead) {
  return new BulkheadMetrics(Array.of(bulkhead));
}

代码示例来源:origin: resilience4j/resilience4j

/**
 * Creates a new instance of {@link BulkheadExports} with default metrics names prefix and
 * a bulkhead as a source.
 *
 * @param prefix the prefix of metrics names
 * @param bulkhead the bulkhead
 */
public static BulkheadExports ofBulkhead(String prefix, Bulkhead bulkhead) {
  return new BulkheadExports(prefix, Array.of(bulkhead));
}

代码示例来源:origin: resilience4j/resilience4j

/**
 * Creates a new instance of {@link BulkheadExports} with default metrics names prefix and
 * a bulkhead as a source.
 *
 * @param bulkhead the bulkhead
 */
public static BulkheadExports ofBulkhead(Bulkhead bulkhead) {
  return new BulkheadExports(Array.of(bulkhead));
}

代码示例来源:origin: resilience4j/resilience4j

/**
 * Creates a new instance of {@link RateLimiterExports} with default metrics names prefix and
 * a rate limiter as a source.
 *
 * @param prefix the prefix of metrics names
 * @param rateLimiter the rate limiter
 */
public static RateLimiterExports ofRateLimiter(String prefix, RateLimiter rateLimiter) {
  return new RateLimiterExports(prefix, Array.of(rateLimiter));
}

代码示例来源:origin: resilience4j/resilience4j

/**
 * Creates a new instance of {@link CircuitBreakerExports} with default metrics names prefix and
 * a circuit breaker as a source.
 *
 * @param circuitBreaker the circuit breaker
 */
public static CircuitBreakerExports ofCircuitBreaker(CircuitBreaker circuitBreaker) {
  requireNonNull(circuitBreaker);
  return new CircuitBreakerExports(Array.of(circuitBreaker));
}

代码示例来源:origin: resilience4j/resilience4j

/**
 * Creates a new instance of {@link RateLimiterExports} with default metrics names prefix and
 * a rate limiter as a source.
 *
 * @param rateLimiter the rate limiter
 */
public static RateLimiterExports ofRateLimiter(RateLimiter rateLimiter) {
  return new RateLimiterExports(Array.of(rateLimiter));
}

代码示例来源:origin: resilience4j/resilience4j

/**
 * Creates a new instance of CircuitBreakerMetrics {@link CircuitBreakerMetrics} with a circuit breaker as a source.
 *
 * @param circuitBreaker the circuit breaker
 */
public static CircuitBreakerMetrics ofCircuitBreaker(CircuitBreaker circuitBreaker) {
  return new CircuitBreakerMetrics(Array.of(circuitBreaker));
}

代码示例来源:origin: resilience4j/resilience4j

public static RetryMetrics ofRetry(Retry retry) {
  return new RetryMetrics(Array.of(retry));
}

代码示例来源:origin: resilience4j/resilience4j

public static AsyncRetryMetrics ofAsyncRetry(AsyncRetry retry) {
  return new AsyncRetryMetrics(Array.of(retry));
}

代码示例来源:origin: vavr-io/vavr

static <T> Array<Array<T>> apply(Array<T> elements, int k) {
    if (k == 0) {
      return Array.of(Array.empty());
    } else {
      return elements.zipWithIndex().flatMap(
          t -> apply(elements.drop(t._2 + 1), (k - 1)).map(c -> c.prepend(t._1))
      );
    }
  }
}

代码示例来源:origin: vavr-io/vavr

@Override
public Array<Array<T>> permutations() {
  if (isEmpty()) {
    return empty();
  } else if (delegate.length == 1) {
    return of(this);
  } else {
    final Array<Array<T>> zero = empty();
    return distinct().foldLeft(zero, (xs, x) -> {
      final Function<Array<T>, Array<T>> prepend = l -> l.prepend(x);
      return xs.appendAll(remove(x).permutations().map(prepend));
    });
  }
}

代码示例来源:origin: jdbi/jdbi

Array<Tuple3<Type, Integer, Option<String>>> resolveKeyValueColumns(ConfigRegistry config, Array<Tuple2<Type, Integer>> tupleTypes) {
  Array<Tuple3<Type, Integer, Option<String>>> withConfiguredColumnName;
  Tuple2<Type, Integer> keyType = tupleTypes.get(0);
  Tuple2<Type, Integer> valueType = tupleTypes.get(1);
  withConfiguredColumnName = Array.of(
      Tuple.of(keyType._1, keyType._2, Option.of(config.get(TupleMappers.class).getKeyColumn())),
      Tuple.of(valueType._1, valueType._2, Option.of(config.get(TupleMappers.class).getValueColumn()))
  );
  return withConfiguredColumnName;
}

代码示例来源:origin: jdbi/jdbi

Array<Tuple2<Type, Integer>> tupleTypes = Array.of(tupleClass.getTypeParameters())
    .map(tp -> resolveType(tp, type))
    .zipWithIndex((t, i) -> Tuple.of(t, i + 1));

代码示例来源:origin: io.vavr/vavr

/**
 * Alias for {@link Array#of(Object)}
 *
 * @param <T>     Component type of element.
 * @param element An element.
 * @return A new {@link Array} instance containing the given element
 */
public static <T> Array<T> Array(T element) {
  return Array.of(element);
}

代码示例来源:origin: vavr-io/vavr-jackson

@Test
public void testArrayOfTuple() throws Exception {
  String src00 = "A";
  String src01 = "B";
  Tuple2<String, String> src0 = Tuple.of(src00, src01);
  Array<Tuple2<String, String>> src = Array.of(src0);
  String json = MAPPER.writeValueAsString(new ParameterizedArrayPojo<>(src));
  Assert.assertEquals(json, "{\"value\":[[\"A\",\"B\"]]}");
  ParameterizedArrayPojo<io.vavr.Tuple2<java.lang.String, java.lang.String>> restored = 
      MAPPER.readValue(json, new TypeReference<ParameterizedArrayPojo<io.vavr.Tuple2<java.lang.String, java.lang.String>>>(){});
  Assert.assertEquals(src, restored.getValue());
}

代码示例来源:origin: netzwerg/paleo

@Test
public void valueTypeSpecificBuilding() {
  BooleanColumn column = builder().add(true).addAll(false, false, true).add(false).build();
  assertEquals(ID, column.getId());
  assertEquals(5, column.getRowCount());
  assertEquals(true, column.getValueAt(0));
  assertEquals(false, column.getValueAt(column.getRowCount() - 1));
  assertEquals(Array.of(true, false, false, true, false), column.valueStream().toArray());
}

相关文章