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

ReactiveSeq.intersperse介绍

[英]Returns a stream with a given value interspersed between any two values of this stream. // (1, 0, 2, 0, 3, 0, 4) ReactiveSeq.of(1, 2, 3, 4).intersperse(0)
[中]返回一个流，该流的任意两个值之间有一个给定值。//（1,0,2,0,3,0,4）反应顺序。of（1,2,3,4）。散布（0）

代码示例

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

/**
 * Returns a stream with a given value interspersed between any two values
 * of this stream.
 *
 *
 * // (1, 0, 2, 0, 3, 0, 4) Streamable.of(1, 2, 3, 4).intersperse(0)
 *
 */
@Override
default Streamable<T> intersperse(final T value) {
  return fromStream(this.stream().intersperse(value));
}

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

@Override
default ImmutableList<T> intersperse(T value) {
  return unitStream(stream().intersperse(value));
}

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

@Override
default ImmutableSet<T> intersperse(T value) {
  return unitStream(stream().intersperse(value));
}

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

@Override
default ImmutableQueue<T> intersperse(T value) {
  return unitStream(stream().intersperse(value));
}

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

@Override
default ImmutableSortedSet<T> intersperse(T value) {
  return unitStream(stream().intersperse(value),comparator());
}

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

@Test
public void testIntersperse() {
  assertThat(Spouts.of(1,2,3).intersperse(0).toList(),equalTo(Arrays.asList(1,0,2,0,3)));
}

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

@Test
public void testIntersperse() {
  assertThat(of(1,2,3).intersperse(0).toList(),equalTo(Arrays.asList(1,0,2,0,3)));
}

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

@Test
public void testIntersperse() {
  assertThat(ReactiveSeq.of(1,2,3).intersperse(0).toList(),equalTo(Arrays.asList(1,0,2,0,3)));
}
@Test

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

@Test
public void testIntersperse() {
  assertThat(Spouts.of(1,2,3).intersperse(0).toList(),equalTo(Arrays.asList(1,0,2,0,3)));
}
@Test

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

@Test
public void testIntersperse() {
  assertThat(of(1,2,3).intersperse(0).toList(),equalTo(Arrays.asList(1,0,2,0,3)));
}

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

@Test
public void testIntersperse() {
  assertThat(ReactiveSeq.of(1,2,3).intersperse(0).toList(),equalTo(Arrays.asList(1,0,2,0,3)));
}

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

@Test
public void testIntersperse() {
  assertThat(of(1,2,3).intersperse(0).toList(),equalTo(Arrays.asList(1,0,2,0,3)));
}

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

/**
 * Returns a stream with a given value interspersed between any two values
 * of this stream.
 *
 *
 * // (1, 0, 2, 0, 3, 0, 4) Streamable.of(1, 2, 3, 4).intersperse(0)
 *
 */
@Override
default Streamable<T> intersperse(final T value) {
  return fromStream(this.stream().intersperse(value));
}

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

@Override
default ImmutableQueue<T> intersperse(T value) {
  return unitStream(stream().intersperse(value));
}

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

@Override
default ImmutableSet<T> intersperse(T value) {
  return unitStream(stream().intersperse(value));
}

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

@Override
default ImmutableList<T> intersperse(T value) {
  return unitStream(stream().intersperse(value));
}

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

@Override
default ImmutableSortedSet<T> intersperse(T value) {
  return unitStream(stream().intersperse(value),comparator());
}

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

/**
 * Returns a stream with a given value interspersed between any two values
 * of this stream.
 *
 *
 * // (1, 0, 2, 0, 3, 0, 4) FutureStream.of(1, 2, 3, 4).actOnFutures().intersperse(0)
 *
 */
default FutureStream<T> intersperse(final T value) {
  return fromStreamOfFutures(this.getLastActive()
                  .injectFuturesSeq()
                  .intersperse(FastFuture.completedFuture(value)));
}

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

/**
 * Returns a stream with a given value interspersed between any two values
 * of this stream.
 *
 * FutureStream.of(1, 2, 3, 4)
 *                 .actOnFutures()
 *                 .intersperse(CompletableFuture.completedFuture(0));
 *
 * // (1, 0, 2, 0, 3, 0, 4)
 *
 */
default FutureStream<T> intersperse(final CompletableFuture<T> value) {
  return fromStreamOfFutures(this.getLastActive()
                  .injectFuturesSeq()
                  .intersperse(FastFuture.fromCompletableFuture(value)));
}