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

ReactiveSeq.appendAll介绍

暂无

代码示例

代码示例来源：origin: aol/micro-server

@Override
public Class[] classes(Config config, Class... classes) {
  List<Class> classList = new ArrayList<Class>();
  classList.addAll(Arrays.asList(classes));
  return ReactiveSeq.fromIterable(new JerseyApplication(classList).classes).appendAll(classList)
          .toArray(i->new Class[i]);
}

代码示例来源：origin: aol/cyclops

@Override
default ReactiveSeq<T> plusAll(Iterable<? extends T> list) {
  return appendAll(list);
}

代码示例来源：origin: aol/cyclops

default Streamable<T> concat(final Streamable<T> other) {
  return fromStream(this.stream().appendAll(other));
}

代码示例来源：origin: aol/cyclops

@Override
default ImmutableSet<T> appendAll(T... values) {
  return unitStream(stream().appendAll(values));
}

代码示例来源：origin: aol/cyclops

@Override
default ImmutableSet<T> appendAll(Iterable<? extends T> value) {
  return unitStream(stream().appendAll(value));
}

代码示例来源：origin: aol/cyclops

default Streamable<T> concat(final T... other) {
  return fromStream(this.stream().appendAll(other));
}

代码示例来源：origin: aol/cyclops

/**
 * Append values to the take of this Streamable
 * <pre>
 * {@code
 * List<String> result = Streamable.of(1,2,3)
 *                                    .append(100,200,300)
                  .map(it ->it+"!!")
                  .collect(CyclopsCollectors.toList());
    assertThat(result,equalTo(Arrays.asList("1!!","2!!","3!!","100!!","200!!","300!!")));
 * }
 * </pre>
 * @param values to append
 * @return Streamable with appended values
 */
default Streamable<T> appendAll(final T... values) {
  return fromStream(this.stream().appendAll(values));
}

代码示例来源：origin: aol/cyclops

@Override
default ImmutableSortedSet<T> appendAll(T... values) {
  return unitStream(stream().appendAll(values),comparator());
}

代码示例来源：origin: aol/cyclops

@Test
public void append(){
  List<String> result =     of(1,2,3).appendAll(100,200,300)
      .map(it ->it+"!!").collect(Collectors.toList());
  assertThat(result,equalTo(Arrays.asList("1!!","2!!","3!!","100!!","200!!","300!!")));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void append(){
  List<String> result =     of(1,2,3).appendAll(100,200,300)
      .map(it ->it+"!!").collect(Collectors.toList());
  assertThat(result,equalTo(Arrays.asList("1!!","2!!","3!!","100!!","200!!","300!!")));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void append(){
  List<String> result =     of(1,2,3).appendAll(100,200,300)
      .map(it ->it+"!!").collect(Collectors.toList());
  assertThat(result,equalTo(Arrays.asList("1!!","2!!","3!!","100!!","200!!","300!!")));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void append(){
  List<String> result =     of(1,2,3).appendAll(100,200,300)
      .map(it ->it+"!!").collect(Collectors.toList());
  assertThat(result,equalTo(Arrays.asList("1!!","2!!","3!!","100!!","200!!","300!!")));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void append() {
  for(int k=0;k<ITERATIONS;k++) {
    List<String> result = of(1, 2, 3).appendAll(100, 200, 300)
        .map(it -> it + "!!").collect(Collectors.toList());
    assertThat(result, equalTo(Arrays.asList("1!!", "2!!", "3!!", "100!!", "200!!", "300!!")));
  }
}

代码示例来源：origin: aol/cyclops

@Test
public void append(){
  List<String> result =     of(1,2,3).appendAll(100,200,300)
      .map(it ->it+"!!").collect(Collectors.toList());
  assertThat(result,equalTo(Arrays.asList("1!!","2!!","3!!","100!!","200!!","300!!")));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void prependAppend(){
  assertThat(of(1)
      .prependStream(Stream.of(2)).append(3).prepend(4).appendAll(5,6)
      .prependAll(7,8)
      .insertAt(4,9).deleteBetween(1,2)
      .insertStreamAt(5,Stream.of(11,12)).stream().count(),equalTo(10L));
}
@Test

代码示例来源：origin: com.oath.cyclops/cyclops

@Override
default ImmutableSet<T> appendAll(Iterable<? extends T> value) {
  return unitStream(stream().appendAll(value));
}

代码示例来源：origin: com.oath.cyclops/cyclops

default Streamable<T> concat(final Streamable<T> other) {
  return fromStream(this.stream().appendAll(other));
}

代码示例来源：origin: com.oath.cyclops/cyclops-futurestream

@Override
default FutureStream<U> appendAll(final U... values) {
  return fromStream(ReactiveSeq.oneShotStream(stream())
                 .appendAll(values));
}

代码示例来源：origin: com.oath.cyclops/cyclops-futurestream

@Override
default FutureStream<U> appendAll(Iterable<? extends U> other) {
  return fromStream(ReactiveSeq.oneShotStream(stream()).appendAll(other));
}

代码示例来源：origin: com.oath.cyclops/cyclops

@Override
default ImmutableSortedSet<T> appendAll(T... values) {
  return unitStream(stream().appendAll(values),comparator());
}