Skip to content

Commit

Permalink
Fix flux adapter sample codes in docs
Browse files Browse the repository at this point in the history 
Signed-off-by: Taeik Lim <[email protected]>
  • Loading branch information
@acktsap
acktsap committed Apr 14, 2024
1 parent d7b3555 commit 7ef021f
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 12 deletions.
12 changes: 6 additions & 6 deletions doc/en/step/item-stream-flux-reader-processor-writer.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ class SampleTasklet implements ItemStreamFluxReaderProcessorWriter<Integer, Stri

@NonNull
@Override
public Flux<Integer> readFlux(@NonNull ExecutionContext executionContext) {
public Flux<? extends Integer> readFlux(@NonNull ExecutionContext executionContext) {
System.out.println("totalCount: " + totalCount);
return Flux.generate(sink -> {
if (count < totalCount) {
Expand Down Expand Up @@ -136,7 +136,7 @@ open class SampleTasklet(
) : ItemStreamFluxReaderProcessorWriter<Int, String> {
private var count = 0

override fun readFlux(executionContext: ExecutionContext): Flux<Int> {
override fun readFlux(executionContext: ExecutionContext): Flux<out Int> {
println("totalCount: $totalCount")
return Flux.generate { sink ->
if (count < totalCount) {
Expand Down Expand Up @@ -201,7 +201,7 @@ class SampleTasklet implements ItemStreamFluxReaderWriter<Integer> {

@NonNull
@Override
public Flux<Integer> readFlux(@NonNull ExecutionContext executionContext) {
public Flux<? extends Integer> readFlux(@NonNull ExecutionContext executionContext) {
System.out.println("totalCount: " + totalCount);
return Flux.generate(sink -> {
if (count < totalCount) {
Expand Down Expand Up @@ -285,7 +285,7 @@ open class SampleTasklet(
) : ItemStreamFluxReaderWriter<Int> {
private var count = 0

override fun readFlux(executionContext: ExecutionContext): Flux<Int> {
override fun readFlux(executionContext: ExecutionContext): Flux<out Int> {
println("totalCount: $totalCount")
return Flux.generate { sink ->
if (count < totalCount) {
Expand Down Expand Up @@ -349,7 +349,7 @@ public class SampleTasklet implements ItemStreamFluxReaderProcessorWriter<Intege

@NonNull
@Override
public Flux<Integer> readFlux(@NonNull ExecutionContext executionContext) {
public Flux<? extends Integer> readFlux(@NonNull ExecutionContext executionContext) {
System.out.println("totalCount: " + totalCount);
return Flux.generate(sink -> {
if (count < totalCount) {
Expand Down Expand Up @@ -437,7 +437,7 @@ open class SampleTasklet(
println("onOpenRead")
}

override fun readFlux(executionContext: ExecutionContext): Flux<Int> {
override fun readFlux(executionContext: ExecutionContext): Flux<out Int> {
println("totalCount: $totalCount")
return Flux.generate { sink ->
if (count < totalCount) {
Expand Down
12 changes: 6 additions & 6 deletions doc/ko/step/item-stream-flux-reader-processor-writer.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ class SampleTasklet implements ItemStreamFluxReaderProcessorWriter<Integer, Stri

@NonNull
@Override
public Flux<Integer> readFlux(@NonNull ExecutionContext executionContext) {
public Flux<? extends Integer> readFlux(@NonNull ExecutionContext executionContext) {
System.out.println("totalCount: " + totalCount);
return Flux.generate(sink -> {
if (count < totalCount) {
Expand Down Expand Up @@ -136,7 +136,7 @@ open class SampleTasklet(
) : ItemStreamFluxReaderProcessorWriter<Int, String> {
private var count = 0

override fun readFlux(executionContext: ExecutionContext): Flux<Int> {
override fun readFlux(executionContext: ExecutionContext): Flux<out Int> {
println("totalCount: $totalCount")
return Flux.generate { sink ->
if (count < totalCount) {
Expand Down Expand Up @@ -201,7 +201,7 @@ class SampleTasklet implements ItemStreamFluxReaderWriter<Integer> {

@NonNull
@Override
public Flux<Integer> readFlux(@NonNull ExecutionContext executionContext) {
public Flux<? extends Integer> readFlux(@NonNull ExecutionContext executionContext) {
System.out.println("totalCount: " + totalCount);
return Flux.generate(sink -> {
if (count < totalCount) {
Expand Down Expand Up @@ -285,7 +285,7 @@ open class SampleTasklet(
) : ItemStreamFluxReaderWriter<Int> {
private var count = 0

override fun readFlux(executionContext: ExecutionContext): Flux<Int> {
override fun readFlux(executionContext: ExecutionContext): Flux<out Int> {
println("totalCount: $totalCount")
return Flux.generate { sink ->
if (count < totalCount) {
Expand Down Expand Up @@ -349,7 +349,7 @@ public class SampleTasklet implements ItemStreamFluxReaderProcessorWriter<Intege

@NonNull
@Override
public Flux<Integer> readFlux(@NonNull ExecutionContext executionContext) {
public Flux<? extends Integer> readFlux(@NonNull ExecutionContext executionContext) {
System.out.println("totalCount: " + totalCount);
return Flux.generate(sink -> {
if (count < totalCount) {
Expand Down Expand Up @@ -437,7 +437,7 @@ open class SampleTasklet(
println("onOpenRead")
}

override fun readFlux(executionContext: ExecutionContext): Flux<Int> {
override fun readFlux(executionContext: ExecutionContext): Flux<out Int> {
println("totalCount: $totalCount")
return Flux.generate { sink ->
if (count < totalCount) {
Expand Down

0 comments on commit 7ef021f

Please sign in to comment.