Commit 0feee47

committed

优化代码

1 parent b997f57 commit 0feee47Copy full SHA for 0feee47

File tree

-1

lines changed

chapter13 Reactive Streams/java9-reactive-demo1/src/main/java/com/dockerx/reactive/jdkaction
- DockerXDemoSubscriber.java

-1

lines changed

Lines changed: 0 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,6 @@ public DockerXDemoSubscriber(long bufferSize,String name) {`
`19`	`19`	`}`
`20`	`20`
`21`	`21`	`public void onSubscribe(Flow.Subscription subscription) {`
`22`		`- this.subscription = subscription;`
`23`	`22`	`count = bufferSize - bufferSize / 2;// 当消费一半的时候重新请求`
`24`	`23`	`(this.subscription = subscription).request(bufferSize);`
`25`	`24`	`}`

Comments

(0)