cyclops.reactive.ReactiveSeq.dropWhileInclusive()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(10.3k)|赞(0)|评价(0)|浏览(81)

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

ReactiveSeq.dropWhileInclusive介绍

暂无

代码示例

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

default ReactiveSeq<T> dropUntilInclusive(final Predicate<? super T> p) {
  return dropWhileInclusive(p.negate());
}

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

@Test(expected= NullPointerException.class)
public void testSkipWhileInclusiveWithNulls() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, null, 3, 4, 5);
  assertTrue(s.get().dropWhileInclusive(i -> true).toList().containsAll(asList(1, 2, null, 3, 4, 5)));
}

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

@Test
public void testSkipWhileInclusive() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5);
  assertTrue(s.get().dropWhileInclusive(i -> false).toList().containsAll(asList(2, 3, 4, 5)));
  assertEquals(asList(), s.get().dropWhile(i -> true).toList());
}

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

@Test
public void testSkipWhileInclusive() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5);
  assertTrue(s.get().dropWhileInclusive(i -> false).toList().containsAll(asList(2, 3, 4, 5)));
  assertEquals(asList(), s.get().dropWhile(i -> true).toList());
}

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

@Test
public void testSkipWhileInclusive() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5);
  assertTrue(s.get().dropWhileInclusive(i -> false).toList().containsAll(asList(2, 3, 4, 5)));
  assertEquals(asList(), s.get().dropWhile(i -> true).toList());
}

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

@Test
public void dropWhileEmptyInclusive() {
  assertThat(of().dropWhileInclusive(p -> true).toList(), equalTo(Arrays.asList()));
}

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

@Test
public void predicateError(){
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Spouts.of(1,2,3,4,5)
    .dropWhileInclusive(i ->{ throw new RuntimeException();})
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  assertThat(data.get(),equalTo(Vector.of()));
  assertThat(complete.get(),equalTo(true));
  assertThat(error.get(),instanceOf(RuntimeException.class));
}
@Test

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

@Test
public void predicateErrorAsync(){
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Spouts.async(ReactiveSeq.of(1,2,3,4,5),ex)
    .dropWhileInclusive(i ->{ throw new RuntimeException();})
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  while(!complete.get()){
    LockSupport.parkNanos(10l);
  }
  assertThat(data.get(),equalTo(Vector.of()));
  assertThat(complete.get(),equalTo(true));
  assertThat(error.get(),instanceOf(RuntimeException.class));
}

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

@Test
public void dropWhile5() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Spouts.of(1,2,3,4,5)
    .dropWhileInclusive(i -> false)
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  assertThat(data.get(),equalTo(Vector.of(2,3,4,5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}
@Test

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

@Test
public void dropWhile5Async() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Spouts.async(ReactiveSeq.of(1,2,3,4,5),ex)
    .dropWhileInclusive(i -> false)
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  while(!complete.get()){
    LockSupport.parkNanos(10l);
  }
  assertThat(data.get(),equalTo(Vector.of(2,3,4,5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}
@Test

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

@Test
public void dropWhile1Async() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Spouts.async(ReactiveSeq.of(1,2,3,4,5),ex)
    .dropWhileInclusive(i -> i<4)
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  while(!complete.get()){
    LockSupport.parkNanos(10l);
  }
  assertThat(data.get(),equalTo(Vector.of(5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}
@Test

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

@Test
public void dropWhile1() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Spouts.of(1,2,3,4,5)
    .dropWhileInclusive(i -> i<5)
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  assertThat(data.get(),equalTo(Vector.of()));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}
@Test

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

@Test
public void dropWhile0() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Spouts.of(1,2,3,4,5)
    .dropWhileInclusive(i -> i<4)
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  assertThat(data.get(),equalTo(Vector.of(5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}
@Test

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

@Test
public void dropWhile0Async() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Spouts.async(ReactiveSeq.of(1,2,3,4,5),ex)
    .dropWhileInclusive(i -> i<0)
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  while(!complete.get()){
    LockSupport.parkNanos(10l);
  }
  assertThat(data.get(),equalTo(Vector.of(2,3,4,5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}

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

@Test
public void dropWhileStages3Async() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Subscription s = Spouts.async(ReactiveSeq.of(1,2,3,4,5),ex)
    .dropWhileInclusive(i -> i<2)
    .forEach(2, n -> {
      assertFalse(complete.get());
      data.updateAndGet(sq -> sq.plus(n));
    }, e -> {
      error.set(e);
    }, () -> {
      complete.set(true);
    });
  while(!complete.get()){
    LockSupport.parkNanos(10l);
  }
  assertThat(data.get(),equalTo(Vector.of(3,4,5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}

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

@Test
public void dropWhileStagesAsync() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Subscription s =  Spouts.async(ReactiveSeq.of(1,2,3,4,5),ex)
    .dropWhileInclusive(i -> false)
    .forEach(2, n -> {
      assertFalse(complete.get());
      data.updateAndGet(sq -> sq.plus(n));
    }, e -> {
      error.set(e);
    }, () -> {
      complete.set(true);
    });
  while(!complete.get()){
    LockSupport.parkNanos(10l);
  }
  assertThat(data.get(),equalTo(Vector.of(2,3,4,5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}
@Test

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

@Test
public void dropWhile4_transforms5() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  AtomicInteger peeks = new AtomicInteger(0);
  Spouts.of(1,2,3,4,5)
    .peek(System.out::println)
    .peek(p->peeks.incrementAndGet())
    .dropWhileInclusive(i -> i<4)
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  assertThat(peeks.get(),equalTo(5));
  assertThat(data.get(),equalTo(Vector.of(5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}
@Test

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

@Test
public void dropWhileStages() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  Subscription s = Spouts.of(1, 2, 3, 4, 5)
    .dropWhileInclusive(i -> false)
    .forEach(2, n -> {
      assertFalse(complete.get());
      data.updateAndGet(sq -> sq.plus(n));
    }, e -> {
      error.set(e);
    }, () -> {
      complete.set(true);
    });
  assertThat(data.get(),equalTo(Vector.of(2,3)));
  assertThat(complete.get(),equalTo(false));
  assertNull(error.get());
  s.request(10l);
  assertThat(data.get(),equalTo(Vector.of(2,3,4,5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}
@Test

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

@Test
public void dropWhile1_transforms5() {
  AtomicReference<Vector<Integer>> data = new AtomicReference(Vector.empty());
  AtomicBoolean complete = new AtomicBoolean(false);
  AtomicReference<Throwable> error = new AtomicReference<Throwable>(null);
  AtomicInteger peeks = new AtomicInteger(0);
  Spouts.of(1,2,3,4,5)
    .peek(System.out::println)
    .peek(p->peeks.incrementAndGet())
    .dropWhileInclusive(i -> i<1)
    .forEach(n->{
      assertFalse(complete.get());
      data.updateAndGet(s->s.plus(n));
    },e->{
      error.set(e);
    },()->{
      complete.set(true);
    });
  assertThat(peeks.get(),equalTo(5));
  assertThat(data.get(),equalTo(Vector.of(2,3,4,5)));
  assertThat(complete.get(),equalTo(true));
  assertNull(error.get());
}
@Test

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

@Test
public void dropWhileInclusive() {
  assertThat(of(1, 2, 3, 4, 5).dropWhileInclusive(p -> p < 6).toList().size(), lessThan(1));
}

内容来源于网络，如有侵权，请联系作者删除！

ReactiveSeq

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ReactiveSeq类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com