cyclops.reactive.ReactiveSeq.debounce()方法的使用及代码示例
本文整理了Java中cyclops.reactive.ReactiveSeq.debounce方法的一些代码示例，展示了ReactiveSeq.debounce的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ReactiveSeq.debounce方法的具体详情如下：
包路径：cyclops.reactive.ReactiveSeq
类名称：ReactiveSeq
方法名：debounce
ReactiveSeq.debounce介绍
[英]Allow one element through per time period, drop all other elements in that time period
ReactiveSeq.of(1,2,3,4,5,6)[中]每个时间段允许一个元素通过，在该时间段删除所有其他元素
ReactiveSeq.of(1,2,3,4,5,6)代码示例
代码示例来源：origin: aol/cyclops
@Test
public void debounceOk(){
System.out.println(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).toList());
assertThat(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounceOk(){
System.out.println(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).toList());
assertThat(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounceOk(){
System.out.println(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).toList());
assertThat(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounceOk(){
System.out.println(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).toList());
assertThat(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounceOk(){
System.out.println(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).toList());
assertThat(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounceOk(){
System.out.println(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).to(Streamable::fromStream).toList());
assertThat(of(1,2,3,4,5,6).debounce(1,TimeUnit.NANOSECONDS).to(Streamable::fromStream).collect(Collectors.toList()).size(),is(6));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounce(){
SimpleTimer timer = new SimpleTimer();
assertThat(of(1,2,3,4,5,6).debounce(1000,TimeUnit.SECONDS).collect(Collectors.toList()).size(),is(1));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounce(){
SimpleTimer timer = new SimpleTimer();
assertThat(of(1,2,3,4,5,6).debounce(1000,TimeUnit.SECONDS).collect(Collectors.toList()).size(),is(1));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounce(){
SimpleTimer timer = new SimpleTimer();
assertThat(of(1,2,3,4,5,6).debounce(1000,TimeUnit.SECONDS).collect(Collectors.toList()).size(),is(1));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounce(){
SimpleTimer timer = new SimpleTimer();
assertThat(of(1,2,3,4,5,6).debounce(1000,TimeUnit.SECONDS).collect(Collectors.toList()).size(),is(1));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void debounce(){
SimpleTimer timer = new SimpleTimer();
assertThat(of(1,2,3,4,5,6).debounce(1000,TimeUnit.SECONDS).to(Streamable::fromStream).collect(Collectors.toList()).size(),is(1));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void reactiveSeq(){
Connectable<String> connectable = ReactiveSeq.of("a", "b", "c", "d", "e")
.peek(x -> System.out.println("peek1:" + x))
.schedule("* * * * * ?", ThreadPools.getStandardSchedular());
System.out.println("resultList:" + connectable.connect().debounce(10, TimeUnit.SECONDS).peek(x->System.out.println("peek2:" + x)).toList() );
}代码示例来源：origin: aol/cyclops
@Test
public void fixedRateTest() throws InterruptedException{
assertThat(of(1,2,3,4)
.peek(i->count.incrementAndGet())
.peek(System.out::println)
.scheduleFixedRate(1000, ex)
.connect()
.debounce(1,TimeUnit.DAYS)
.peek(System.out::println)
.toList(),equalTo(Arrays.asList(1)));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void cronDebounceTest() throws InterruptedException{
assertThat(of(1,2,3,4)
.peek(i->count.incrementAndGet())
.peek(System.out::println)
.schedule("* * * * * ?", ex)
.connect()
.debounce(1,TimeUnit.DAYS)
.peek(System.out::println)
.toList(),equalTo(Arrays.asList(1)));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void cronDebounceTest() throws InterruptedException{
assertThat(of(1,2,3,4)
.peek(i->count.incrementAndGet())
.peek(System.out::println)
.schedule("* * * * * ?", ex)
.connect()
.debounce(1,TimeUnit.DAYS)
.peek(System.out::println)
.toList(),equalTo(Arrays.asList(1)));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void fixedRateTest() throws InterruptedException{
assertThat(of(1,2,3,4)
.peek(i->count.incrementAndGet())
.peek(System.out::println)
.scheduleFixedRate(1000, ex)
.connect()
.debounce(1,TimeUnit.DAYS)
.peek(System.out::println)
.toList(),equalTo(Arrays.asList(1)));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void cronDebounceTest() throws InterruptedException{
assertThat(Spouts.of(1,2,3,4)
.peek(i->count.incrementAndGet())
.peek(System.out::println)
.schedule("* * * * * ?", ex)
.connect()
.debounce(1,TimeUnit.DAYS)
.peek(System.out::println)
.toList(),equalTo(Arrays.asList(1)));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void fixedRateDelay() throws InterruptedException{
assertThat(Spouts.of(1,2,3,4)
.peek(i->count.incrementAndGet())
.peek(System.out::println)
.scheduleFixedDelay(1000, ex)
.connect()
.debounce(1,TimeUnit.DAYS)
.peek(System.out::println)
.toList(),equalTo(Arrays.asList(1)));
}
}代码示例来源：origin: aol/cyclops
@Test
public void fixedRateTest() throws InterruptedException{
assertThat(Spouts.of(1,2,3,4)
.peek(i->count.incrementAndGet())
.peek(System.out::println)
.scheduleFixedRate(1000, ex)
.connect()
.debounce(1,TimeUnit.DAYS)
.peek(System.out::println)
.toList(),equalTo(Arrays.asList(1)));
}
@Test代码示例来源：origin: aol/cyclops
@Test
public void fixedRateDelay() throws InterruptedException{
assertThat(ReactiveSeq.of(1,2,3,4)
.peek(i->count.incrementAndGet())
.peek(System.out::println)
.scheduleFixedDelay(1000, ex)
.connect()
.debounce(1,TimeUnit.DAYS)
.peek(System.out::println)
.toList(),equalTo(Arrays.asList(1)));
}
}内容来源于网络，如有侵权，请联系作者删除！
