本文整理了Java中cyclops.reactive.ReactiveSeq.deleteBetween
方法的一些代码示例,展示了ReactiveSeq.deleteBetween
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ReactiveSeq.deleteBetween
方法的具体详情如下:
包路径:cyclops.reactive.ReactiveSeq
类名称: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));
}
内容来源于网络,如有侵权,请联系作者删除!