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

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

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

ReactiveSeq.elementAtAndStream介绍

[英]Gets the element at index, and returns a Tuple containing the element (it must be present) and a maybe copy of the Sequence for further processing.

ReactiveSeq.of(1,2,3,4,5).getValue(2)._1

[中]获取索引处的元素,并返回一个元组,其中包含元素(它必须存在)和序列的副本,以便进一步处理

ReactiveSeq.of(1,2,3,4,5).getValue(2)._1

代码示例

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

@Test(expected=NoSuchElementException.class)
public void getMultiple1(){
  of(1).elementAtAndStream(1);
}
@Test(expected=NoSuchElementException.class)

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

@Test(expected=NoSuchElementException.class)
public void getEmpty(){
  ReactiveSeq.of().elementAtAndStream(0);
}
@Test

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

@Test(expected=NoSuchElementException.class)
public void getEmpty(){
  Spouts.of().elementAtAndStream(0);
}
@Test

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

@Test(expected=NoSuchElementException.class)
public void getEmpty(){
  of().elementAtAndStream(0);
}
@Test

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

@Test(expected=NoSuchElementException.class)
public void getEmpty(){
  of().elementAtAndStream(0);
}
@Test

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

@Test(expected=NoSuchElementException.class)
public void getMultiple1(){
  of(1).elementAtAndStream(1);
}
@Test(expected=NoSuchElementException.class)

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

@Test(expected=NoSuchElementException.class)
public void getMultiple1(){
  ReactiveSeq.of(1).elementAtAndStream(1);
}
@Test(expected=NoSuchElementException.class)

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

@Test
public void getMultple(){
  assertThat(of(1,2,3,4,5).elementAtAndStream(2)._1(),equalTo(3));
}
@Test

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

@Test
public void getMultpleStream(){
  assertThat(of(1,2,3,4,5).elementAtAndStream(2)._2().toList(),equalTo(Arrays.asList(1,2,3,4,5)));
}
@Test(expected=NoSuchElementException.class)

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

@Test
public void elementAt0(){
  assertThat(of(1).elementAtAndStream(0)._1(),equalTo(1));
}
@Test

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

@Test
public void getMultpleStream(){
  assertThat(Spouts.of(1,2,3,4,5).elementAtAndStream(2)._2().toList(),equalTo(Arrays.asList(1,2,3,4,5)));
}
@Test(expected=NoSuchElementException.class)

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

@Test
public void elementAt0(){
  assertThat(of(1).elementAtAndStream(0)._1(),equalTo(1));
}
@Test

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

@Test
public void getMultple(){
  assertThat(of(1,2,3,4,5).elementAtAndStream(2)._1(),equalTo(3));
}
@Test

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

@Test
public void getMultpleStream(){
  assertThat(Spouts.of(1,2,3,4,5).elementAtAndStream(2)._2().toList(),equalTo(Arrays.asList(1,2,3,4,5)));
}
@Test(expected=NoSuchElementException.class)

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

@Test
public void elementAt0(){
  assertThat(Spouts.of(1).elementAtAndStream(0)._1(),equalTo(1));
}
@Test

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

@Test
public void getMultpleStream(){
  assertThat(of(1,2,3,4,5).elementAtAndStream(2)._2().toList(),equalTo(Arrays.asList(1,2,3,4,5)));
}
@Test(expected=NoSuchElementException.class)

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

@Test
public void getMultpleStream(){
  assertThat(ReactiveSeq.of(1,2,3,4,5).elementAtAndStream(2)._2().toList(),equalTo(Arrays.asList(1,2,3,4,5)));
}
@Test(expected=NoSuchElementException.class)

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

@Test
public void getMultpleStream(){
  assertThat(of(1,2,3,4,5).elementAtAndStream(2)._2().toList(),equalTo(Arrays.asList(1,2,3,4,5)));
}
@Test(expected=NoSuchElementException.class)

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

@Test
public void elementAt0(){
  assertThat(ReactiveSeq.of(1).elementAtAndStream(0)._1(),equalTo(1));
}
@Test

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

@Test
public void groupedShorter() throws Exception {
  final Streamable<Integer> fixed = Streamable.fromStream(Stream.of(5, 7, 9));
  assertThat(fixed.stream().grouped(4).elementAtAndStream(0)._1(),equalTo(Vector.of(5,7,9)));
  assertThat(fixed.stream().grouped(4).count(),equalTo(1l));
}

相关文章

微信公众号

最新文章

更多

ReactiveSeq类方法