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

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

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

ReactiveSeq.splitAtHead介绍

[英]Split a Stream at it's head (similar to headAndTail)

ReactiveSeq.of(1,2,3)

[中]在流的头部拆分流（类似于headAndTail）<<0$>>

代码示例

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

default Tuple2<Option<T>, Streamable<T>> splitAtHead(){
  return this.stream().splitAtHead().map2(s->Streamable.fromStream(s));
}

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

@Test
public void splitAtHeadInvestigate() {
  System.out.println("0" + of(1, 2, 3).splitAt(0)._2().toList());
  System.out.println(of(1, 2, 3).splitAtHead()._1());
  System.out.println(of(1, 2, 3).splitAtHead()._2().toList());
  System.out.println(of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  System.out.println(of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertThat(of(1, 2, 3).splitAtHead()._2().toList(), equalTo(Arrays.asList(2, 3)));
}

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

@Test
public void splitThenSplit(){
  assertThat(of(1,2,3).to().option(),equalTo(Option.of(LazySeq.of(1,2,3))));
  // System.out.println(of(1, 2, 3).splitAtHead()._2.listX());
  System.out.println("split " + of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
}
@Test

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

@Test
public void splitThenSplit(){
  assertThat(of(1,2,3).to().option(),equalTo(Option.of(LazySeq.of(1,2,3))));
  // System.out.println(of(1, 2, 3).splitAtHead().v2.listX());
  System.out.println("split " + of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
}
@Test

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

@Test
public void splitThenSplit() {
  assertThat(of(1, 2, 3).to().option(), equalTo(Option.of(LazySeq.of(1, 2, 3))));
  // System.out.println(of(1, 2, 3).splitAtHead()._2.listX());
  System.out.println("split " + of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  ReactiveSeq<Integer> x = of(1, 2, 3).splitAtHead()._2()
    .splitAtHead()._2();
  System.out.println("s is  " + x.seq());
  Option<Integer> o = of(1, 2, 3).splitAtHead()._2()
                .splitAtHead()._2()
                .splitAtHead()._1();
  System.out.println("o is " + o);
  assertEquals(Option.of(3), o);
}

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

@Test
public void splitThenSplit(){
  assertThat(of(1,2,3).to().option(),equalTo(Option.of(LazySeq.of(1,2,3))));
  // System.out.println(of(1, 2, 3).splitAtHead().v2.listX());
  System.out.println("split " + of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
}
@Test

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

@Test
public void testSplitAtHead() {
  assertEquals(asList(), of(1).splitAtHead()._2().toList());
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1).splitAtHead()._1());
  assertEquals(Option.of(1), of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), of(1, 2, 3).splitAtHead()._2().toList());
  assertEquals(asList(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void testSplitSequenceAtHead() {
  assertEquals(asList(), Spouts.of(1).splitAtHead()._2().toList());
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), Spouts.of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), Spouts.of(1).splitAtHead()._1());
  assertEquals(Option.of(1), Spouts.of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), Spouts.of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), Spouts.of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), Spouts.of(1, 2, 3).splitAtHead()._2().toList());
  assertEquals(asList(3), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void testSplitSequenceAtHead() {
  assertEquals(asList(), ReactiveSeq.of(1).splitAtHead()._2().toList());
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), ReactiveSeq.of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), ReactiveSeq.of(1).splitAtHead()._1());
  assertEquals(Option.of(1), ReactiveSeq.of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), ReactiveSeq.of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), ReactiveSeq.of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), ReactiveSeq.of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), ReactiveSeq.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), ReactiveSeq.of(1, 2, 3).splitAtHead()._2().toList());
  assertEquals(asList(3), ReactiveSeq.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), ReactiveSeq.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void testSplitSequenceAtHead() {
  assertEquals(asList(), Spouts.of(1).splitAtHead()._2().toList());
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), Spouts.of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), Spouts.of(1).splitAtHead()._1());
  assertEquals(Option.of(1), Spouts.of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), Spouts.of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), Spouts.of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), Spouts.of(1, 2, 3).splitAtHead()._2().toList());
  assertEquals(asList(3), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void testSplitAtHead() {
  assertEquals(asList(), Spouts.of(1).splitAtHead()._2().toList());
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), Spouts.of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), Spouts.of(1).splitAtHead()._1());
  assertEquals(Option.of(1), Spouts.of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), Spouts.of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), Spouts.of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), Spouts.of(1, 2, 3).splitAtHead()._2().toList());
  assertEquals(asList(3), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void testSplitAtHead() {
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1).splitAtHead()._1());
  assertEquals(asList(), of(1).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), of(1, 2, 3).splitAtHead()._2().toList());
   assertEquals(asList(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void splitThenSplit(){
  Tuple2<ReactiveSeq<Integer>, ReactiveSeq<Integer>> dup = Spouts.of(1, 2, 3).duplicate();
  dup._1().printOut();
  System.out.println("V2..");
  dup._2().printOut();
  assertEquals(Option.of(2), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(2l), Spouts.rangeLong(1, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(2), Spouts.range(1, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(2), Spouts.fromIterable(Arrays.asList(1, 2, 3)).splitAtHead()._2().splitAtHead()._1());
}

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

@Test
public void testSplitAtHead() {
  assertEquals(asList(), Spouts.of(1).splitAtHead()._2().toList());
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), Spouts.of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), Spouts.of(1).splitAtHead()._1());
  assertEquals(Option.of(1), Spouts.of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), Spouts.of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), Spouts.of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), Spouts.of(1, 2, 3).splitAtHead()._2().toList());
  assertEquals(asList(3), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), Spouts.of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void testSplitSequenceAtHead() {
  assertEquals(asList(), of(1).splitAtHead()._2().toList());
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1).splitAtHead()._1());
  assertEquals(Option.of(1), of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), of(1, 2, 3).splitAtHead()._2().toList());
  assertEquals(asList(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void testSplitAtHead() {
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1).splitAtHead()._1());
  assertEquals(asList(), of(1).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), of(1, 2, 3).splitAtHead()._2().toList());
   assertEquals(asList(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}
@Override

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

@Test
public void testSplitAtHead() {
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1).splitAtHead()._1());
  assertEquals(asList(), of(1).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), of(1, 2, 3).splitAtHead()._2().toList());
   assertEquals(asList(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}
@Test

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

@Test
public void testSplitSequenceAtHead() {
  assertEquals(asList(), of(1).splitAtHead()._2().toList());
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1).splitAtHead()._1());
  assertEquals(Option.of(1), of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), of(1, 2, 3).splitAtHead()._2().toList());
  assertEquals(asList(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void testSplitAtHead() {
  assertEquals(asList(), of(1).splitAtHead()._2().toList());
  assertEquals(Option.none(), of().splitAtHead()._1());
  assertEquals(asList(), of().splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1).splitAtHead()._1());
  assertEquals(Option.of(1), of(1, 2).splitAtHead()._1());
  assertEquals(asList(2), of(1, 2).splitAtHead()._2().toList());
  assertEquals(Option.of(1), of(1, 2, 3).splitAtHead()._1());
  assertEquals(Option.of(2), of(1, 2, 3).splitAtHead()._2().splitAtHead()._1());
  assertEquals(Option.of(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._1());
  assertEquals(asList(2, 3), of(1, 2, 3).splitAtHead()._2().toList());
  assertEquals(asList(3), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  assertEquals(asList(), of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().splitAtHead()._2().toList());
}

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

@Test
public void splitAtHeadBug(){
  final Tuple2<ReactiveSeq<Integer>, ReactiveSeq<Integer>> Tuple2 = ReactiveSeq.of(1).splitAt(1);
  Option<LazySeq<Integer>> a = Tuple2._1().to().option();
  Option<Option<Integer>> x = a
    .flatMap(l -> l.size() > 0 ? Option.of(l.get(0)) : Option.none());
  assertEquals(Option.of(1), ReactiveSeq.of(1).splitAtHead()._1());
}
@Test

内容来源于网络，如有侵权，请联系作者删除！

ReactiveSeq

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ReactiveSeq类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com