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

ReactiveSeq.takeRight介绍

暂无

代码示例

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

@Override
  public String getType(Class c) {
    return Maybe.ofNullable(c.getPackage())
          .map(Package::getName)
          .map(packageName -> packageName.split("\\."))
          .stream()
          .flatMap(Stream::of)
          .takeRight(1)
          .single()
          .map(i -> i + ".")
          .orElse("")
        + c.getSimpleName();
  }
}

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

public static final  <T> Function1<? super Iterable<T>,? extends T> tail(){
  return it -> ReactiveSeq.fromIterable(it)
              .takeRight(1)
              .firstValue(null);
}
public static final  <T> Function1<? super Iterable<T>,? extends T> reduce(Monoid<T> monoid){

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

default Maybe<Long> lastIndexOf(Predicate<? super T> pred){
 return stream().zipWithIndex()
         .filter(p->pred.test(p._1()))
         .takeRight(1)
         .takeOne()
         .map(v->v._2());
}
default Maybe<Long> indexOfSlice(Iterable<? extends T> slice){

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

@Test
public void testLimitLast1(){
  assertThat(of(1,2,3,4,5)
      .takeRight(1)
      .findFirst().get(),equalTo(5));
  assertThat(of(1,2,3,4,5)
      .takeRight(1)
      .collect(Collectors.toList()),equalTo(Arrays.asList(5)));
}
@Test

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

@Test
public void testLimitLastEmpty(){
  assertThat(Spouts.of()
            .takeRight(2)
            .collect(Collectors.toList()),equalTo(Arrays.asList()));
}
@Test

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

@Test
public void testLimitLast(){
  assertThat(of(1,2,3,4,5)
            .takeRight(2)
            .collect(Collectors.toList()),equalTo(Arrays.asList(4,5)));
}
@Test

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

@Test
public void testLimitLast1(){
  assertThat(of(1,2,3,4,5)
      .takeRight(1)
      .collect(Collectors.toList()),equalTo(Arrays.asList(5)));
}
@Test

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

@Test
public void testLimitLastEmpty(){
  assertThat(ReactiveSeq.of()
            .takeRight(2)
            .collect(Collectors.toList()),equalTo(Arrays.asList()));
}
@Test

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

@Test
public void testLimitLast(){
  assertThat(of(1,2,3,4,5)
            .takeRight(2)
            .collect(Collectors.toList()),equalTo(Arrays.asList(4,5)));
}
@Test

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

@Test
public void testLimitLast(){
  assertThat(Spouts.of(1,2,3,4,5)
            .takeRight(2)
            .collect(Collectors.toList()),equalTo(Arrays.asList(4,5)));
}
@Test

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

@Test
public void testLimitLastEmpty(){
  assertThat(of()
      .takeRight(2)
      .collect(Collectors.toList()),equalTo(Arrays.asList()));
}
@Test

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

@Test
public void testLimitLast(){
  assertThat(ReactiveSeq.of(1,2,3,4,5)
            .takeRight(2)
            .collect(Collectors.toList()),equalTo(Arrays.asList(4,5)));
}
@Test

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

@Test
public void testLimitLastEmpty(){
  assertThat(of()
            .takeRight(2)
            .collect(Collectors.toList()),equalTo(Arrays.asList()));
}
@Test

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

@Test
public void testLimitLast1Empty(){
  assertThat(of()
      .takeRight(1)
      .collect(Collectors.toList()),equalTo(Arrays.asList()));
}
@Test

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

@Test
public void testLimitLast1(){
  assertThat(Spouts.of(1,2,3,4,5)
      .takeRight(1)
      .to(Streamable::fromStream).collect(Collectors.toList()),equalTo(Arrays.asList(5)));
}
@Test

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

@Test
public void takeRightValues(){
  assertThat(of(1,2,3).takeRight(-1).seq(), Matchers.equalTo(of().seq()));
  assertThat(of(1,2,3).takeRight(0).seq(), Matchers.equalTo(of().seq()));
  assertThat(of(1,2,3).takeRight(1).seq(), Matchers.equalTo(of(3).seq()));
  assertThat(of(1,2,3).takeRight(2).seq(), Matchers.equalTo(of(2,3).seq()));
  assertThat(of(1,2,3).takeRight(3).seq(), Matchers.equalTo(of(1,2,3).seq()));
  assertThat(of(1,2,3).takeRight(4).seq(), Matchers.equalTo(of(1,2,3).seq()));
}
@Test

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

@Test
public void lastOneBug(){
  assertThat(of(1, 2, 3, 4)
      .takeRight(1)
      .single()
      .orElse(-1),equalTo(4));
}

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

@Test
public void iterate(){
  ReactiveSeq<Integer> s = ReactiveSeq.iterate(1,i->i+1);
  assertThat(s.limit(10).takeRight(1).asFunction().apply(0l),equalTo(10));
  assertThat(s.limit(10).takeRight(1).asFunction().apply(0l),equalTo(10));
}

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

@Test
public void takeRightValues(){
  assertThat(of(1,2,3).takeRight(-1).seq(), equalTo(of().seq()));
  assertThat(of(1,2,3).takeRight(0).seq(), equalTo(of().seq()));
  assertThat(of(1,2,3).takeRight(1).seq(), equalTo(of(3).seq()));
  assertThat(of(1,2,3).takeRight(2).seq(), equalTo(of(2,3).seq()));
  assertThat(of(1,2,3).takeRight(3).seq(), equalTo(of(1,2,3).seq()));
  assertThat(of(1,2,3).takeRight(4).seq(), equalTo(of(1,2,3).seq()));
}
@Test

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

@Test @Ignore
public void limitLast(){
  AsyncSubscriber<String> pushable = Spouts.asyncSubscriber();
  ReactiveSeq<String> stream = pushable.stream();
  pushable.onNext("hello1");
  pushable.onNext("hello2");
  pushable.onNext("hello3");
  pushable.onComplete();
  // stream.printOut();
  stream.takeRight(2).zipWithStream(Stream.of(1,2)).printOut();
}