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

ReactiveSeq.rangeLong介绍

[英]Create an efficiently reversable Sequence that produces the integers between skip and take
[中]创建一个高效可反转的序列，生成skip和take之间的整数

代码示例

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

@Override
default ImmutableList<Tuple2<T, Long>> zipWithIndex() {
  return zipWithStream(ReactiveSeq.rangeLong(0,Long.MAX_VALUE));
  // return unitStream(stream().zipWithIndex());
}

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

/**
 * Create an efficiently reversable Sequence that produces the integers between skip
 * and take
 * @param start Number of range to skip from
 * @param end Number for range to take at
 * @return Range Streamable
 */
public static Streamable<Long> rangeLong(final long start, final long end) {
  return fromStream(ReactiveSeq.rangeLong(start, end));
}

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

public static ReactiveSeq<Long> rangeLong(final long start, final  long step,final long end) {
  if(start>end)
    return rangeLong(end,step,start);
  final ReversingRangeLongSpliterator range = new ReversingRangeLongSpliterator(
      start, end, step,false);
  return Streams.reactiveSeq(range, Optional.ofNullable(range));
}

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

@Test
public void reversedRangeLong(){
  assertThat(ReactiveSeq.rangeLong(10, -10).count(),equalTo(20L));
}
@Test

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

@Test
public void longStreamCompare(){
  assertThat(LongStream.range(-1l,10l).sum(),
      equalTo(ReactiveSeq.rangeLong(-1l,10l).sumLong(i->i)));
}
@Test

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

@Test
public void rangeLongSkip(){
  assertThat(ReactiveSeq.rangeLong(0,5)
      .skip(3).toList(),equalTo(Arrays.asList(3l,4l)));
}
@Test

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

@Test
public void longStreamCompare0(){
  assertThat(LongStream.range(0,10).sum(),
      equalTo(ReactiveSeq.rangeLong(0,10).sumLong(i->i)));
}
@Test

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

@Test
public void rangeLong(){
  assertThat(ReactiveSeq.rangeLong(0,Long.MAX_VALUE)
      .limit(2).toList(),equalTo(Arrays.asList(0l,1l)));
}
@Test

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

@Test
public void rangeLongReversedSkip(){
  assertThat(ReactiveSeq.rangeLong(0,5).reverse()
      .skip(3).toList(),equalTo(Arrays.asList(1l,0l)));
}
@Test

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

@Test
public void longStreamCompareReversed(){
  assertThat(0L,
      equalTo(ReactiveSeq.rangeLong(-5,6).reverse().sumLong(i->i)));
}
@Test

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

@Test
public void negativeLong(){
  assertThat(ReactiveSeq.rangeLong(-1000L,Long.MAX_VALUE)
      .limit(100)
      .count(),equalTo(100L));
}
@Test

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

@Test
public void reversedRangeLongWithReverse(){
  assertThat(ReactiveSeq.rangeLong(10, -10).reverse().count(),equalTo(20L));
}
@Test

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

@Test
public void rangeLongReversed(){
  assertThat(ReactiveSeq.rangeLong(0,Long.MAX_VALUE).reverse()
      .limit(2).toList(),equalTo(Arrays.asList(9223372036854775806l, 9223372036854775805l)));
}
@Test

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

@Test
public void skipRangeLong() throws InterruptedException{
  assertThat(ReactiveSeq.rangeLong(0,1000)
      .skip(100)
      .count(),equalTo(900L));
}
@Test

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

@Test
public void rangeLongMultiReverse(){
  assertThat(ReactiveSeq.rangeLong(0,5).reverse().reverse().count(),equalTo(5l));
}
@Test

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

@Test
public void rangeLong(){
  ReactiveSeq.rangeLong(0,5).reverse().reverse().reverse().printOut();
  of('a').zipWithStream(ReactiveSeq.rangeLong(0,100)).printOut();
}
@Test

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

@Test
public void hotStreamCaptureLong() throws InterruptedException{
  List<Long> list = ReactiveSeq.rangeLong(0,Long.MAX_VALUE)
      .limit(1000)
      .primedHotStream(exec)
      .connect()
      .limit(2)
      .toList();
  assertThat(list,equalTo(Arrays.asList(0l,1l)));
}
@Test

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

@Test
public void take2ReversedLong(){
  System.out.println(Spouts.rangeLong(0,10).vector());
  System.out.println(ReactiveSeq.range(0,10).vector());
  System.out.println(range(0,10).reverse().vector());
  System.out.println(ReactiveSeq.range(0,10).reverse().vector());
  System.out.println(ReactiveSeq.rangeLong(0,10).reverse().vector());
  assertThat(rangeLong(0,10).reverse().take(2).toList(),equalTo(Arrays.asList(9l,8l)));
}
@Test

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

@Test
public void take2ReversedLong(){
  System.out.println(Spouts.rangeLong(0,10).vector());
  System.out.println(ReactiveSeq.range(0,10).vector());
  System.out.println(range(0,10).reverse().vector());
  System.out.println(ReactiveSeq.range(0,10).reverse().vector());
  System.out.println(ReactiveSeq.rangeLong(0,10).reverse().vector());
  assertThat(rangeLong(0,10).reverse().take(2).toList().size(),equalTo(2));
  assertThat(rangeLong(0,10).reverse().take(2).toList(),not(contains(10)));
}

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

@Test
public void longs(){
  assertThat(ReactiveSeq.rangeLong(1, 1000).longs(i->i,s->s.map(i->i*2).filter(i->i<500))
             .size(),equalTo(249));
}