Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit cd42f91

Browse files
14章第一个Demo
1 parent 21eaf24 commit cd42f91

File tree

4 files changed

+79
-0
lines changed

4 files changed

+79
-0
lines changed

‎chapter13 Reactive Streams/info.md

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
# Java-9-Spring-Webflux
2+
本章博文 : process的讲解
3+
4+
​ Reactive Streams 中背压的实现

‎chapter14/info.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
# Java-9-Spring-Webflux
2+
hello

‎chapter14/java9-reactive-rxjava/pom.xml

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<modelVersion>4.0.0</modelVersion>
6+
7+
<groupId>com.dockerx.reactive</groupId>
8+
<artifactId>java9-reactive-rxjava</artifactId>
9+
<version>1.0-SNAPSHOT</version>
10+
<properties>
11+
<java.version>1.9</java.version>
12+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
13+
</properties>
14+
<dependencies>
15+
<dependency>
16+
<groupId>io.reactivex.rxjava2</groupId>
17+
<artifactId>rxjava</artifactId>
18+
<version>2.1.7</version>
19+
</dependency>
20+
</dependencies>
21+
<build>
22+
<plugins>
23+
<plugin>
24+
<groupId>org.apache.maven.plugins</groupId>
25+
<artifactId>maven-compiler-plugin</artifactId>
26+
<version>3.6.1</version>
27+
<configuration>
28+
<source>${java.version}</source>
29+
<target>${java.version}</target>
30+
<showDeprecation>true</showDeprecation>
31+
<showWarnings>true</showWarnings>
32+
</configuration>
33+
</plugin>
34+
</plugins>
35+
</build>
36+
37+
</project>
Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
package com.dockerx.reactive.rxjava;
2+
3+
import java.math.BigInteger;
4+
import java.util.Iterator;
5+
6+
/**
7+
* @author Author 知秋
8+
* @email fei6751803@163.com
9+
* @time Created by Auser on 2017年12月28日 0:34.
10+
*/
11+
public class GenerateNumbersIterator implements Iterator{
12+
private BigInteger current = BigInteger.ZERO;
13+
private BigInteger num;
14+
15+
public GenerateNumbersIterator(BigInteger num) {
16+
this.num = num;
17+
}
18+
19+
@Override
20+
public boolean hasNext() {
21+
return current.compareTo(num)<0;
22+
}
23+
24+
@Override
25+
public Object next() {
26+
current = current.add(BigInteger.ONE);
27+
return current;
28+
}
29+
30+
public static void main(String[] args) {
31+
GenerateNumbersIterator generateNumbersIterator=new GenerateNumbersIterator(BigInteger.valueOf(10L));
32+
while (generateNumbersIterator.hasNext()){
33+
System.out.println(generateNumbersIterator.next());
34+
}
35+
}
36+
}

0 commit comments

Comments
(0)

AltStyle によって変換されたページ (->オリジナル) /