cyclops.reactive.ReactiveSeq.deleteBetween()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(5.3k)|赞(0)|评价(0)|浏览(158)

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

ReactiveSeq.deleteBetween介绍

[英]Delete elements between given indexes in a Stream

List result = ReactiveSeq.of(1, 2, 3, 4, 5, 6).deleteBetween(2, 4).map(it -> it + "!!").collect(CyclopsCollectors.toList());

[中]删除流中给定索引之间的元素

List result = ReactiveSeq.of(1, 2, 3, 4, 5, 6).deleteBetween(2, 4).map(it -> it + "!!").collect(CyclopsCollectors.toList());

代码示例

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

/**
 * Return a Stream with elements before the provided skip index removed,
 * and elements after the provided take index removed
 *
 * <pre>
 * {@code
 *   ReactiveSeq.of(1,2,3,4,5,6).subStream(1,3);
 *
 *
 *   //ReactiveSeq[2,3]
 * }
 * </pre>
 *
 * @param start
 *            index inclusive
 * @param end
 *            index exclusive
 * @return Sequence between supplied indexes of original Sequence
 */
default ReactiveSeq<T> subStream(final int start, final int end) {
  return this.limit(end)
        .deleteBetween(0, start);
}

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

@Override
default ImmutableList<T> deleteBetween(int start, int end) {
  return unitStream(stream().deleteBetween(start,end));
}

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

@Override
default ImmutableSet<T> deleteBetween(int start, int end) {
  return unitStream(stream().deleteBetween(start,end));
}

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

@Override
default ImmutableQueue<T> deleteBetween(int start, int end) {
  return unitStream(stream().deleteBetween(start,end));
}

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

/**
 * Delete elements between given indexes in a Stream
 * <pre>
 * {@code
 * List<String> result =     Streamable.of(1,2,3,4,5,6)
 *                                      .deleteBetween(2,4)
                   .map(it ->it+"!!")
                   .collect(CyclopsCollectors.toList());
    assertThat(result,equalTo(Arrays.asList("1!!","2!!","5!!","6!!")));
 * }
 * </pre>
 * @param start index
 * @param end index
 * @return Stream with elements removed
 */
default Streamable<T> deleteBetween(final int start, final int end) {
  return fromStream(this.stream().deleteBetween(start, end));
}

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

@Override
default ImmutableSortedSet<T> deleteBetween(int start, int end) {
  return unitStream(stream().deleteBetween(start,end),comparator());
}

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

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

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

/**
 * Return a Stream with elements before the provided skip index removed,
 * and elements after the provided take index removed
 *
 * <pre>
 * {@code
 *   ReactiveSeq.of(1,2,3,4,5,6).subStream(1,3);
 *
 *
 *   //ReactiveSeq[2,3]
 * }
 * </pre>
 *
 * @param start
 *            index inclusive
 * @param end
 *            index exclusive
 * @return Sequence between supplied indexes of original Sequence
 */
default ReactiveSeq<T> subStream(final int start, final int end) {
  return this.limit(end)
        .deleteBetween(0, start);
}

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

@Override
default FutureStream<U> deleteBetween(final int start, final int end) {
  return fromStream(stream().deleteBetween(start, end));
}

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

@Override
default ImmutableQueue<T> deleteBetween(int start, int end) {
  return unitStream(stream().deleteBetween(start,end));
}

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

@Override
default ImmutableSet<T> deleteBetween(int start, int end) {
  return unitStream(stream().deleteBetween(start,end));
}

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

@Override
default ImmutableList<T> deleteBetween(int start, int end) {
  return unitStream(stream().deleteBetween(start,end));
}

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

/**
 * Delete elements between given indexes in a Stream
 * <pre>
 * {@code
 * List<String> result =     Streamable.of(1,2,3,4,5,6)
 *                                      .deleteBetween(2,4)
                   .map(it ->it+"!!")
                   .collect(CyclopsCollectors.toList());
    assertThat(result,equalTo(Arrays.asList("1!!","2!!","5!!","6!!")));
 * }
 * </pre>
 * @param start index
 * @param end index
 * @return Stream with elements removed
 */
default Streamable<T> deleteBetween(final int start, final int end) {
  return fromStream(this.stream().deleteBetween(start, end));
}

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

@Override
default ImmutableSortedSet<T> deleteBetween(int start, int end) {
  return unitStream(stream().deleteBetween(start,end),comparator());
}

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

/**
 * Delete elements between given indexes in a Stream
 *
 * <pre>
 * {@code
 * List<String> result =     of(1,2,3,4,5,6).actOnFutures()
                        .deleteBetween(2,4)
                        .map(it ->it+"!!")
                        .collect(CyclopsCollectors.toList());
    assertThat(result,equalTo(Arrays.asList("1!!","2!!","5!!","6!!")));
 *
 * }
 * </pre>
 *
 * @param start
 *            index
 * @param end
 *            index
 * @return Stream with elements removed
 */
default FutureStream<T> deleteBetween(final int start, final int end) {
  return fromStreamOfFutures(this.getLastActive()
                  .injectFuturesSeq()
                  .deleteBetween(start, end));
}

相关文章

微信公众号

最新文章

更多

ReactiveSeq类方法