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

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

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

ReactiveSeq.unzip4介绍

[英]Unzip a zipped Stream into 4

unzip4(ReactiveSeq.of(new Tuple4(1, "a", 2l,'reactiveSeq'), new Tuple4(2, "b", 3l,'y'), new Tuple4(3,// ReactiveSeq[1,2,3], ReactiveSeq[a,b,c], ReactiveSeq[2l,3l,4l], ReactiveSeq[reactiveSeq,y,x]

[中]将压缩后的流解压缩为4

unzip4(ReactiveSeq.of(new Tuple4(1, "a", 2l,'reactiveSeq'), new Tuple4(2, "b", 3l,'y'), new Tuple4(3,// ReactiveSeq[1,2,3], ReactiveSeq[a,b,c], ReactiveSeq[2l,3l,4l], ReactiveSeq[reactiveSeq,y,x]

代码示例

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

@Test
public void testUnzip4() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().toList().containsAll(Arrays.asList(1, 2, 3)));
  assertTrue(u1._2().toList().containsAll(asList("a", "b", "c")));
  assertTrue(u1._3().toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().toList().containsAll(Arrays.asList(1, 2, 3)));
  assertTrue(u1._2().toList().containsAll(asList("a", "b", "c")));
  assertTrue(u1._3().toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().toList().containsAll(Arrays.asList(1, 2, 3)));
  assertTrue(u1._2().toList().containsAll(asList("a", "b", "c")));
  assertTrue(u1._3().toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().toList().containsAll(Arrays.asList(1, 2, 3)));
  assertTrue(u1._2().toList().containsAll(asList("a", "b", "c")));
  assertTrue(u1._3().toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().toList().containsAll(Arrays.asList(1, 2, 3)));
  assertTrue(u1._2().toList().containsAll(asList("a", "b", "c")));
  assertTrue(u1._3().toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().toList().containsAll(Arrays.asList(1, 2, 3)));
  assertTrue(u1._2().toList().containsAll(asList("a", "b", "c")));
  assertTrue(u1._3().toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4WithLimits() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().limit(1).toList().containsAll(Arrays.asList(1)));
  assertTrue(u1._2().limit(2).toList().containsAll(asList("a", "b")));
  assertTrue(u1._3().limit(3).toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().limit(4).toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4WithLimits() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().limit(1).toList().containsAll(Arrays.asList(1)));
  assertTrue(u1._2().limit(2).toList().containsAll(asList("a", "b")));
  assertTrue(u1._3().limit(3).toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().limit(4).toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4WithLimits() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().limit(1).toList().containsAll(Arrays.asList(1)));
  assertTrue(u1._2().limit(2).toList().containsAll(asList("a", "b")));
  assertTrue(u1._3().limit(3).toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().limit(4).toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4WithLimits() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().limit(1).toList().containsAll(Arrays.asList(1)));
  assertTrue(u1._2().limit(2).toList().containsAll(asList("a", "b")));
  assertTrue(u1._3().limit(3).toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().limit(4).toList().containsAll(asList('z', 'y', 'x')));
}

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

@Test
public void testUnzip4WithLimits() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().limit(1).toList().containsAll(Arrays.asList(1)));
  assertTrue(u1._2().limit(2).toList().containsAll(asList("a", "b")));
  assertTrue(u1._3().limit(3).toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().limit(4).toList().containsAll(asList('z', 'y', 'x')));
}

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

/**
 * Unzip a zipped Stream into 4
 *
 * <pre>
 * {@code
 * unzip4(Streamable.of(new Tuple4(1, "a", 2l,'µ'), new Tuple4(2, "b", 3l,'y'), new Tuple4(3,
          "c", 4l,'x')));
  }
  // Streamable[1,2,3], Streamable[a,b,c], Streamable[2l,3l,4l], Streamable[µ,y,x]
 * </pre>
 */
public static <T1, T2, T3, T4> Tuple4<Streamable<T1>, Streamable<T2>, Streamable<T3>, Streamable<T4>> unzip4(
    final Streamable<Tuple4<T1, T2, T3, T4>> sequence) {
  return ReactiveSeq.unzip4(sequence.stream())
           .map1(s -> fromStream(s))
           .map2(s -> fromStream(s))
           .map3(s -> fromStream(s))
           .map4(s -> fromStream(s));
}

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

@Test
public void testUnzip4WithLimits() {
  Supplier<ReactiveSeq<Tuple4<Integer, String, Long, Character>>> s = () -> of(new Tuple4(1, "a", 2l, 'z'), new Tuple4(2, "b", 3l, 'y'), new Tuple4(3, "c",
      4l, 'x'));
  Tuple4<ReactiveSeq<Integer>, ReactiveSeq<String>, ReactiveSeq<Long>, ReactiveSeq<Character>> u1 = ReactiveSeq.unzip4(s.get());
  assertTrue(u1._1().limit(1).to(Streamable::fromStream).toList().containsAll(Arrays.asList(1)));
  assertTrue(u1._2().limit(2).to(Streamable::fromStream).toList().containsAll(asList("a", "b")));
  assertTrue(u1._3().limit(3).to(Streamable::fromStream).toList().containsAll(asList(2l, 3l, 4l)));
  assertTrue(u1._4().limit(4).to(Streamable::fromStream).toList().containsAll(asList('z', 'y', 'x')));
}
@Test

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

/**
 * Unzip a zipped Stream into 4
 *
 * <pre>
 * {@code
 * unzip4(Streamable.of(new Tuple4(1, "a", 2l,'µ'), new Tuple4(2, "b", 3l,'y'), new Tuple4(3,
          "c", 4l,'x')));
  }
  // Streamable[1,2,3], Streamable[a,b,c], Streamable[2l,3l,4l], Streamable[µ,y,x]
 * </pre>
 */
public static <T1, T2, T3, T4> Tuple4<Streamable<T1>, Streamable<T2>, Streamable<T3>, Streamable<T4>> unzip4(
    final Streamable<Tuple4<T1, T2, T3, T4>> sequence) {
  return ReactiveSeq.unzip4(sequence.stream())
           .map1(s -> fromStream(s))
           .map2(s -> fromStream(s))
           .map3(s -> fromStream(s))
           .map4(s -> fromStream(s));
}

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

ReactiveSeq

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    ReactiveSeq类方法

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