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

ReactiveSeq.insertAt介绍

[英]Insert data into a ReactiveSeq at a given position

List result = ReactiveSeq.of(1, 2, 3).insertAt(1, 100, 200, 300).map(it -> it + "!!").collect(CyclopsCollectors.toList());

[中]将数据插入到给定位置的ReactiveSeq中

List result = ReactiveSeq.of(1, 2, 3).insertAt(1, 100, 200, 300).map(it -> it + "!!").collect(CyclopsCollectors.toList());

代码示例

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

default ReactiveSeq<T> insertAt(int pos, T value){
  return insertAt(pos,(T[])new Object[]{value});
}
default ReactiveSeq<T> insertAt(int pos, Iterable<? extends T> values){

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

/**
 * Insert data into a stream at given position
 * <pre>
 * {@code
 * List<String> result =     Streamable.of(1,2,3)
 *                                      .insertAt(1,100,200,300)
                   .map(it ->it+"!!")
                   .collect(CyclopsCollectors.toList());
    assertThat(result,equalTo(Arrays.asList("1!!","100!!","200!!","300!!","2!!","3!!")));
 *
 * }
 * </pre>
 * @param pos to insert data at
 * @param values to insert
 * @return Stream with new data inserted
 */
default Streamable<T> insertAt(final int pos, final T... values) {
  return fromStream(this.stream().insertAt(pos, values));
}

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

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

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

@Override
default ImmutableQueue<T> insertAt(int pos, T values) {
  if(pos==0)
    return prependAll(values);
  if(pos>=size())
    return append(values);
  return unitStream(stream().insertAt(pos,values));
}

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

@Override
default ImmutableQueue<T> insertAt(int pos, T... values) {
  if(pos==0)
    return prependAll(values);
  if(pos>=size())
    return appendAll(values);
  return unitStream(stream().insertAt(pos,values));
}
@Override

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

@Test
public void plusAllSize(){
  ReactiveSeq<Integer> vec = Spouts.empty();
  vec = vec.insertAt(Math.max(0,vec.size()),Spouts.of(1));
  System.out.println("Vec1 " + vec.vector());
  vec = vec.insertAt(Math.max(0,vec.size()),Spouts.of(2));
  // System.out.println("Vec " + vec.vector());
  /**Iterator<Integer> it = vec.iterator();
  while(it.hasNext()){
    System.out.println(it.next());
  }**/
  assertThat(vec,equalTo(Spouts.of(1,2)));
}
@Test

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

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

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

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

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

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

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

@Test
public void insertAtOutOfRangeEmptyValue() {
  for(int k=0;k<ITERATIONS;k++) {
    List<String> result = of().insertAt(1, 10)
        .map(it -> it + "!!").collect(Collectors.toList());
    assertThat(result, equalTo(Arrays.asList("10!!")));
  }
}
@Test

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

default ReactiveSeq<T> insertAt(int pos, T value){
  return insertAt(pos,(T[])new Object[]{value});
}
default ReactiveSeq<T> insertAt(int pos, Iterable<? extends T> values){

代码示例来源：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-futurestream

@Override
default FutureStream<U> insertAt(final int pos, final U... values) {
  return fromStream(stream().insertAt(pos, values));
}

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

/**
 * Insert data into a stream at given position
 * <pre>
 * {@code
 * List<String> result =     Streamable.of(1,2,3)
 *                                      .insertAt(1,100,200,300)
                   .map(it ->it+"!!")
                   .collect(CyclopsCollectors.toList());
    assertThat(result,equalTo(Arrays.asList("1!!","100!!","200!!","300!!","2!!","3!!")));
 *
 * }
 * </pre>
 * @param pos to insert data at
 * @param values to insert
 * @return Stream with new data inserted
 */
default Streamable<T> insertAt(final int pos, final T... values) {
  return fromStream(this.stream().insertAt(pos, values));
}

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

@Override
default FutureStream<U> insertAt(int pos, U value) {
  return fromStream(ReactiveSeq.oneShotStream(stream())
      .insertAt(pos,value));
}

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

@Override
default FutureStream<U> insertAt(int pos, Iterable<? extends U> values) {
  return fromStream(ReactiveSeq.oneShotStream(stream())
      .insertAt(pos,values));
}

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

@Override
default FutureStream<U> insertAt(int pos, ReactiveSeq<? extends U> values) {
  return fromStream(ReactiveSeq.oneShotStream(stream())
      .insertAt(pos,values));
}

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

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

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

@Override
default ImmutableQueue<T> insertAt(int pos, T values) {
  if(pos==0)
    return prependAll(values);
  if(pos>=size())
    return append(values);
  return unitStream(stream().insertAt(pos,values));
}

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

@Override
default ImmutableQueue<T> insertAt(int pos, T... values) {
  if(pos==0)
    return prependAll(values);
  if(pos>=size())
    return appendAll(values);
  return unitStream(stream().insertAt(pos,values));
}
@Override