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

ReactiveSeq.slice介绍

暂无

代码示例

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

@Override
default ImmutableQueue<T> slice(long from, long to) {
  return unitStream(stream().slice(from,to));
}

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

@Override
default Streamable<T> slice(final long from, final long to) {
  return fromStream(this.stream().slice(from, to));
}

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

@Override
default ImmutableList<T> slice(long from, long to) {
  return unitStream(stream().slice(from,to));
}

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

@Override
default ImmutableSet<T> slice(long from, long to) {
  return unitStream(stream().slice(from,to));
}

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

@Override
default ImmutableSortedSet<T> slice(long from, long to) {
  return unitStream(stream().slice(from,to),comparator());
}

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

@Override
default ImmutableQueue<T> slice(long from, long to) {
  return unitStream(stream().slice(from,to));
}

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

@Override
default Streamable<T> slice(final long from, final long to) {
  return fromStream(this.stream().slice(from, to));
}

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

@Override
default ImmutableSet<T> slice(long from, long to) {
  return unitStream(stream().slice(from,to));
}

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

@Override
default ImmutableList<T> slice(long from, long to) {
  return unitStream(stream().slice(from,to));
}

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

@Override
default FutureStream<U> slice(final long from, final long to) {
  return fromStream(ReactiveSeq.oneShotStream(stream()
                           .slice(from, to)));
}

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

@Override
default ImmutableSortedSet<T> slice(long from, long to) {
  return unitStream(stream().slice(from,to),comparator());
}

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

/**
 * Returns a limited interval from a given Stream.
 *<pre>
 *{@code
 *
 *         FutureStream.of(1, 2, 3, 4, 5, 6).actOnFutures().slice(3, 5)
 *    // (4, 5)
 * }
 * </pre>
 *
 */
default FutureStream<T> slice(final long from, final long to) {
  return fromStreamOfFutures(this.getLastActive()
                  .injectFuturesSeq()
                  .slice(from, to));
}

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

/**
 * Returns a limited interval from a given Stream.
 *
 * <pre>
 * {@code
 * // (4, 5) EagerFutureStream.of(1, 2, 3, 4, 5, 6).sliceFutures(3, 5)
 * }
 *</pre>
 * @see #slice(long, long)
 */
default SimpleReactStream<U> slice(final long from, final long to) {
  final List noType = ReactiveSeq.fromStream(getLastActive().stream())
              .slice(from, to)
              .collect(Collectors.toList());
  return fromListCompletableFuture(noType);
}