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

ReactiveSeq.empty介绍

暂无

代码示例

代码示例来源：origin: aol/micro-server

public MicroserverPlugins(Class... classes){
  ReactiveSeq<Class> rs=  classes!=null ? ReactiveSeq.of(classes) : ReactiveSeq.empty();
  this.classes = rs
    .appendStream(ReactiveSeq.of(new MicroserverApp(true,extractClass(),()->"").classes))
    .toArray(i->new Class[i]);
}
public MicroserverPlugins(Module mod, Class... classes){

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

default <R> ReactiveSeq<R> fanOut(Function<? super ReactiveSeq<T>, ? extends ReactiveSeq<? extends R>> path1,
                 Function<? super ReactiveSeq<T>, ? extends ReactiveSeq<? extends R>> path2,
                 Function<? super ReactiveSeq<T>, ? extends ReactiveSeq<? extends R>> path3,
                 Function<? super ReactiveSeq<T>, ? extends ReactiveSeq<? extends R>> path4){
  Seq<ReactiveSeq<T>> list = multicast(4);
  Publisher<R> pub2 = (Publisher<R>)path2.apply(list.getOrElse(1,empty()));
  Publisher<R> pub3 = (Publisher<R>)path3.apply(list.getOrElse(2,empty()));
  Publisher<R> pub4 = (Publisher<R>)path4.apply(list.getOrElse(3,empty()));
  ReactiveSeq<R> seq = (ReactiveSeq<R>)path1.apply(list.getOrElse(0,empty()));
  return  seq.mergeP(pub2,pub3,pub4);
}
default <R> ReactiveSeq<R> parallelFanOut(ForkJoinPool fj,Function<? super Stream<T>, ? extends Stream<? extends R>> path1,

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

default <R> ReactiveSeq<R> fanOut(Function<? super ReactiveSeq<T>, ? extends ReactiveSeq<? extends R>> path1,
                 Function<? super ReactiveSeq<T>, ? extends ReactiveSeq<? extends R>> path2,
                 Function<? super ReactiveSeq<T>, ? extends ReactiveSeq<? extends R>> path3){
  Seq<ReactiveSeq<T>> list = multicast(3);
  Publisher<R> pub2 = (Publisher<R>)path2.apply(list.getOrElse(1,empty()));
  Publisher<R> pub3 = (Publisher<R>)path3.apply(list.getOrElse(2,empty()));
  ReactiveSeq<R> seq = (ReactiveSeq<R>)path1.apply(list.getOrElse(0,empty()));
  return  seq.mergeP(pub2,pub3);
}
default <R> ReactiveSeq<R> parallelFanOut(ForkJoinPool fj,Function<? super Stream<T>, ? extends Stream<? extends R>> path1,

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

default <R1,R2,R3> ReactiveSeq<R3> fanOutZipIn(Function<? super ReactiveSeq<T>, ? extends ReactiveSeq<? extends R1>> path1,
                        Function<? super ReactiveSeq<T>, ? extends ReactiveSeq<? extends R2>> path2,
                         BiFunction<? super R1, ? super R2, ? extends R3> zipFn){
  Seq<ReactiveSeq<T>> list = multicast(2);
  return path1.apply(list.getOrElse(0,empty())).zip(path2.apply(list.getOrElse(1,empty())),zipFn);
}
default <R1,R2,R3> ReactiveSeq<R3> parallelFanOutZipIn(ForkJoinPool fj, Function<? super Stream<T>, ? extends Stream<? extends R1>> path1,

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

public static  <T> Optional<ReactiveSeq<T>> sequence(ReactiveSeq<? extends Optional<T>> stream) {
 Optional<ReactiveSeq<T>> identity = Optional.of(ReactiveSeq.empty());
 BiFunction<Optional<ReactiveSeq<T>>,Optional<T>,Optional<ReactiveSeq<T>>> combineToStream = (acc,next) ->zip(acc,next,(a,b)->a.append(b));
 BinaryOperator<Optional<ReactiveSeq<T>>> combineStreams = (a,b)-> zip(a,b,(z1,z2)->z1.appendStream(z2));
 return stream.reduce(identity,combineToStream,combineStreams);
}
public static <T,R> Optional<ReactiveSeq<R>> traverse(Function<? super T,? extends R> fn,ReactiveSeq<Optional<T>> stream) {

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

public static  <T> CompletableFuture<ReactiveSeq<T>> sequence(ReactiveSeq<? extends CompletableFuture<T>> stream) {
 CompletableFuture<ReactiveSeq<T>> identity = CompletableFuture.completedFuture(ReactiveSeq.empty());
 BiFunction<CompletableFuture<ReactiveSeq<T>>,CompletableFuture<T>,CompletableFuture<ReactiveSeq<T>>> combineToStream = (acc,next) ->acc.thenCombine(next,(a,b)->a.append(b));
 BinaryOperator<CompletableFuture<ReactiveSeq<T>>> combineStreams = (a,b)-> a.thenCombine(b,(z1,z2)->z1.appendStream(z2));
 return stream.reduce(identity,combineToStream,combineStreams);
}
public static <T,R> CompletableFuture<ReactiveSeq<R>> traverse(Function<? super T,? extends R> fn,ReactiveSeq<CompletableFuture<T>> stream) {

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

@Override
@SuppressWarnings("unchecked")
public Tuple4<ReactiveSeq<T>, ReactiveSeq<T>, ReactiveSeq<T>, ReactiveSeq<T>> quadruplicate(Supplier<Deque<T>> bufferFactory) {
  Seq<Iterable<T>> copy = Streams.toBufferingCopier(() -> Spliterators.iterator(copy()), 4,bufferFactory);
  return Tuple.tuple(createSeq(new IteratableSpliterator<>(copy.getOrElseGet(0,()->ReactiveSeq.empty()))),
      createSeq(new IteratableSpliterator<>(copy.getOrElseGet(1,()->ReactiveSeq.empty()))),
      createSeq(new IteratableSpliterator<>(copy.getOrElseGet(2,()->ReactiveSeq.empty()))),
      createSeq(new IteratableSpliterator<>(copy.getOrElseGet(3,()->ReactiveSeq.empty()))));
}

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

@Override
@SuppressWarnings("unchecked")
public Tuple3<ReactiveSeq<T>, ReactiveSeq<T>, ReactiveSeq<T>> triplicate(Supplier<Deque<T>> bufferFactory) {
  Seq<Iterable<T>> copy = Streams.toBufferingCopier(() -> Spliterators.iterator(copy()), 3,bufferFactory);
  return Tuple.tuple(createSeq(new IteratableSpliterator<>(copy.getOrElseGet(0,()->ReactiveSeq.empty()))),
      createSeq(new IteratableSpliterator<>(copy.getOrElseGet(1,()->ReactiveSeq.empty()))),
      createSeq(new IteratableSpliterator<>(copy.getOrElseGet(2,()->ReactiveSeq.empty()))));
}

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

@Override
public Tuple2<ReactiveSeq<T>, ReactiveSeq<T>> duplicate() {
  Seq<Iterable<T>> copy = Streams.toBufferingCopier(() -> Spliterators.iterator(copy()), 2);
  return Tuple.tuple(createSeq(new IteratableSpliterator<>(copy.getOrElseGet(0,()->ReactiveSeq.empty()))),
      createSeq(new IteratableSpliterator<>(copy.getOrElseGet(1,()->ReactiveSeq.empty()))));
}
@Override

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

@Override
public Tuple2<ReactiveSeq<T>, ReactiveSeq<T>> duplicate(Supplier<Deque<T>> bufferFactory) {
  Seq<Iterable<T>> copy = Streams.toBufferingCopier(() -> Spliterators.iterator(copy()), 2,bufferFactory);
  return Tuple.tuple(createSeq(new IteratableSpliterator<>(copy.getOrElseGet(0,()->ReactiveSeq.empty()))),
      createSeq(new IteratableSpliterator<>(copy.getOrElseGet(1,()->ReactiveSeq.empty()))));
}

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

public static  <L1,L2,L3,L4,T> LazyEither5<L1, L2, L3, L4,ReactiveSeq<T>> sequence(ReactiveSeq<? extends LazyEither5<L1, L2, L3, L4, T>> stream) {
 LazyEither5<L1, L2, L3, L4, ReactiveSeq<T>> identity = right(ReactiveSeq.empty());
 BiFunction<LazyEither5<L1, L2, L3, L4, ReactiveSeq<T>>,LazyEither5<L1, L2, L3, L4, T>,LazyEither5<L1, L2, L3, L4,ReactiveSeq<T>>> combineToStream = (acc,next) ->acc.zip(next,(a,b)->a.append(b));
 BinaryOperator<LazyEither5<L1, L2, L3, L4,ReactiveSeq<T>>> combineStreams = (a,b)-> a.zip(b,(z1,z2)->z1.appendStream(z2));
 return stream.reduce(identity,combineToStream,combineStreams);
}
public static <L1,L2,L3,L4,T,R> LazyEither5<L1, L2, L3, L4, ReactiveSeq<R>> traverse(Function<? super T,? extends R> fn,ReactiveSeq<LazyEither5<L1, L2, L3,L4,T>> stream) {

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

public static  <T> Eval<ReactiveSeq<T>> sequence(ReactiveSeq<? extends Eval<T>> stream) {
 Eval<ReactiveSeq<T>> identity = Eval.now(ReactiveSeq.empty());
 BiFunction<Eval<ReactiveSeq<T>>,Eval<T>,Eval<ReactiveSeq<T>>> combineToStream = (acc, next) ->acc.zipWith(next,(a, b)->a.append(b));
 BinaryOperator<Eval<ReactiveSeq<T>>> combineStreams = (a, b)-> a.zipWith(b,(z1, z2)->z1.appendStream(z2));
 return stream.reduce(identity,combineToStream,combineStreams);
}
public static <T,R> Eval<ReactiveSeq<R>> traverse(Function<? super T, ? extends R> fn, ReactiveSeq<Eval<T>> stream) {

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

public static  <T> Option<ReactiveSeq<T>> sequence(ReactiveSeq<? extends Option<T>> stream) {
 Option<ReactiveSeq<T>> identity = Option.some(ReactiveSeq.empty());
 BiFunction<Option<ReactiveSeq<T>>,Option<T>,Option<ReactiveSeq<T>>> combineToStream = (acc,next) ->acc.zip(next,(a,b)->a.append(b));
 BinaryOperator<Option<ReactiveSeq<T>>> combineStreams = (a,b)-> a.zip(b,(z1,z2)->z1.appendStream(z2));
 return stream.reduce(identity,combineToStream,combineStreams);
}
public static <T,R> Option<ReactiveSeq<R>> traverse(Function<? super T,? extends R> fn,ReactiveSeq<Option<T>> stream) {

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

public static  <L1,L2,T> LazyEither3<L1,L2,ReactiveSeq<T>> sequence(ReactiveSeq<? extends LazyEither3<L1,L2,T>> stream) {
 LazyEither3<L1,L2, ReactiveSeq<T>> identity = right(ReactiveSeq.empty());
 BiFunction<LazyEither3<L1,L2,ReactiveSeq<T>>,LazyEither3<L1,L2,T>,LazyEither3<L1,L2,ReactiveSeq<T>>> combineToStream = (acc,next) ->acc.zip(next,(a,b)->a.append(b));
 BinaryOperator<LazyEither3<L1,L2,ReactiveSeq<T>>> combineStreams = (a,b)-> a.zip(b,(z1,z2)->z1.appendStream(z2));
 return stream.reduce(identity,combineToStream,combineStreams);
}
public static <L1,L2,T,R> LazyEither3<L1,L2,ReactiveSeq<R>> traverse(Function<? super T,? extends R> fn,ReactiveSeq<LazyEither3<L1,L2,T>> stream) {

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

public static  <L1,L2,L3,T> LazyEither4<L1, L2, L3, ReactiveSeq<T>> sequence(ReactiveSeq<? extends LazyEither4<L1, L2, L3, T>> stream) {
 LazyEither4<L1, L2, L3, ReactiveSeq<T>> identity = right(ReactiveSeq.empty());
 BiFunction<LazyEither4<L1, L2, L3, ReactiveSeq<T>>,LazyEither4<L1, L2, L3, T>,LazyEither4<L1, L2, L3,ReactiveSeq<T>>> combineToStream = (acc,next) ->acc.zip(next,(a,b)->a.append(b));
 BinaryOperator<LazyEither4<L1, L2, L3,ReactiveSeq<T>>> combineStreams = (a,b)-> a.zip(b,(z1,z2)->z1.appendStream(z2));
 return stream.reduce(identity,combineToStream,combineStreams);
}
public static <L1,L2,L3,T,R> LazyEither4<L1, L2, L3, ReactiveSeq<R>> traverse(Function<? super T,? extends R> fn,ReactiveSeq<LazyEither4<L1, L2, L3,T>> stream) {

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

public static  <L,T> Ior<L,ReactiveSeq<T>> sequence(ReactiveSeq<? extends Ior<L,T>> stream) {
 Ior<L, ReactiveSeq<T>> identity = right(ReactiveSeq.empty());
 BiFunction<Ior<L,ReactiveSeq<T>>,Ior<L,T>,Ior<L,ReactiveSeq<T>>> combineToStream = (acc,next) ->acc.zip(next,(a,b)->a.append(b));
 BinaryOperator<Ior<L,ReactiveSeq<T>>> combineStreams = (a,b)-> a.zip(b,(z1,z2)->z1.appendStream(z2));
 return stream.reduce(identity,combineToStream,combineStreams);
}
public static <L,T,R> Ior<L,ReactiveSeq<R>> traverse(Function<? super T,? extends R> fn,ReactiveSeq<Ior<L,T>> stream) {

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

public static  <T> Future<ReactiveSeq<T>> sequence(ReactiveSeq<? extends Future<T>> stream) {
 Future<ReactiveSeq<T>> identity = Future.ofResult(ReactiveSeq.empty());
 BiFunction<Future<ReactiveSeq<T>>,Future<T>,Future<ReactiveSeq<T>>> combineToStream = (acc,next) ->acc.zip(next,(a,b)->a.append(b));
 BinaryOperator<Future<ReactiveSeq<T>>> combineStreams = (a,b)-> a.zip(b,(z1,z2)->z1.appendStream(z2));
 return stream.reduce(identity,combineToStream,combineStreams);
}
public static <T,R> Future<ReactiveSeq<R>> traverse(Function<? super T,? extends R> fn,ReactiveSeq<Future<T>> stream) {

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

@Test
public void shouldReturnEmptySeqWhenZipNonEmptyWithEmptyStream() throws Exception {
  final IterableX<Integer> zipped = of(1,2,3).zipWithStream(ReactiveSeq.<Integer>empty(), (a, b) -> a + b);
  assertTrue(zipped.collect(Collectors.toList()).isEmpty());
}
@Test

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

@Test
public void shouldReturnEmptySeqWhenZipNonEmptyWithEmptyPublisherWith() throws Exception {
  final IterableX<Tuple2<Integer,Integer>> zipped = of(1,2,3).zipWithPublisher(ReactiveSeq.empty());
  assertTrue(zipped.collect(Collectors.toList()).isEmpty());
}

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

/**
 * @return A Stream containing the Head if present
 */
public ReactiveSeq<T> headStream() {
  return isHeadPresent() ? ReactiveSeq.of(head)
    .map(Supplier::get)
    : ReactiveSeq.empty();
}