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

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

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

ReactiveSeq.sliding介绍

[英]Create a sliding view over this Sequence

List> list = ReactiveSeq.of(1, 2, 3, 4, 5, 6).sliding(2).collect(CyclopsCollectors.toList());

[中]在此序列上创建滑动视图

List> list = ReactiveSeq.of(1, 2, 3, 4, 5, 6).sliding(2).collect(CyclopsCollectors.toList());

代码示例

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

@Override
default ImmutableSortedSet<Seq<T>> sliding(int windowSize, int increment) {
  return unitStream(stream().sliding(windowSize,increment));
}

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

@Override
default ImmutableList<Seq<T>> sliding(int windowSize) {
  return unitStream(stream().sliding(windowSize));
}

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

@Override
default ImmutableList<Seq<T>> sliding(int windowSize, int increment) {
  return unitStream(stream().sliding(windowSize,increment));
}

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

@Override
default ImmutableSortedSet<Seq<T>> sliding(int windowSize) {
  return unitStream(stream().sliding(windowSize));
}

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

@Override
default ImmutableQueue<Seq<T>> sliding(int windowSize, int increment) {
  return unitStream(stream().sliding(windowSize,increment));
}

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

default Maybe<Long> indexOfSlice(Iterable<? extends T> slice){
  LazySeq<? extends T> ls = LazySeq.fromIterable(slice);
  Predicate<? super Seq<? super T>> pred = in -> in.equals(ls);
  return stream().sliding(ls.size(),1).indexOf(pred);
}
default Maybe<Long> lastIndexOfSlice(Iterable<? extends T> slice){

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

default Maybe<Long> lastIndexOfSlice(Iterable<? extends T> slice){
  LazySeq<? extends T> ls = LazySeq.fromIterable(slice);
  Predicate<? super Seq<? super T>> pred = in -> in.equals(ls);
  return stream().sliding(ls.size(),1).lastIndexOf(pred);
}

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

@Test
public void slidingEmpty() {
  System.out.println("List " + ReactiveSeq.of().sliding(1).toList());
  assertThat(ReactiveSeq.of().sliding(1).toList().size(),equalTo(0));
}

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

@Test
public void slidingEmpty() {
  System.out.println("List " + of().sliding(1).toList());
  assertThat(of().sliding(1).toList().size(),equalTo(0));
}

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

@Test
public void slidingIncrement() {
  List<Seq<Integer>> list = ReactiveSeq.of(1, 2, 3, 4, 5, 6).sliding(3, 2).collect(Collectors.toList());
  System.out.println(list);
  assertThat(list.get(0), hasItems(1, 2, 3));
  assertThat(list.get(1), hasItems(3, 4, 5));
}

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

@Test
public void slidingIncrement() {
  List<Seq<Integer>> list = of(1, 2, 3, 4, 5, 6).sliding(3, 2).collect(Collectors.toList());
  System.out.println(list);
  assertThat(list.get(0), hasItems(1, 2, 3));
  assertThat(list.get(1), hasItems(3, 4, 5));
}

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

@Test
public void sliding() {
  List<Seq<Integer>> list = of(1, 2, 3, 4, 5, 6).sliding(2).collect(Collectors.toList());
  assertThat(list.get(0), hasItems(1, 2));
  assertThat(list.get(1), hasItems(2, 3));
}

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

@Test
public void sliding() {
  List<Seq<Integer>> list = ReactiveSeq.of(1, 2, 3, 4, 5, 6).sliding(2).collect(Collectors.toList());
  assertThat(list.get(0), hasItems(1, 2));
  assertThat(list.get(1), hasItems(2, 3));
}

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

@Test
public void slidingOverlap() {
  List<Seq<Integer>> sliding = ReactiveSeq.of(1, 2, 3, 4, 5).sliding(3,2).toList();
  assertThat(sliding, contains(Seq.of(1, 2, 3), Seq.of(3, 4, 5)));
}

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

@Test
public void slidingOverlap() {
  List<Seq<Integer>> sliding = of(1, 2, 3, 4, 5).sliding(3,2).toList();
  assertThat(sliding, contains(Seq.of(1, 2, 3), Seq.of(3, 4, 5)));
}

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

@Test
public void slidingWithSmallWindowAtEnd() {
  List<Seq<Integer>> sliding = ReactiveSeq.of(1, 2, 3, 4, 5).sliding(2,2).toList();
  assertThat(sliding, contains(Seq.of(1, 2), Seq.of(3, 4), Seq.of(5)));
}
@Test

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

@Test
public void sliding2() {
  List<Seq<Integer>> sliding = ReactiveSeq.of(1, 2, 3, 4, 5).sliding(2).toList();
  assertThat(sliding, contains(Seq.of(1, 2), Seq.of(2, 3), Seq.of(3, 4), Seq.of(4, 5)));
}

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

@Test
public void sliding2() {
  List<Seq<Integer>> sliding = of(1, 2, 3, 4, 5).sliding(2).toList();
  assertThat(sliding, contains(Seq.of(1, 2), Seq.of(2, 3), Seq.of(3, 4), Seq.of(4, 5)));
}

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

@Test
public void slidingWithSmallWindowAtEndIterative() {
  Iterator<Seq<Integer>> it =  of(1, 2, 3, 4, 5).sliding(2,2).iterator();
  List<Seq<Integer>> sliding = ReactiveSeq.fromIterator(it).toList();
  assertThat(sliding, contains(Seq.of(1, 2), Seq.of(3, 4), Seq.of(5)));
}

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

@Test
public void slidingWithSmallWindowAtEndIterative() {
  Iterator<Seq<Integer>> it =  ReactiveSeq.of(1, 2, 3, 4, 5).sliding(2,2).iterator();
  List<Seq<Integer>> sliding = ReactiveSeq.fromIterator(it).toList();
  assertThat(sliding, contains(Seq.of(1, 2), Seq.of(3, 4), Seq.of(5)));
}

相关文章

微信公众号

最新文章

更多

ReactiveSeq类方法