Skip to content

Commit

Permalink
Deprecate ItemStreamReaderDelegate related adapters
Browse files Browse the repository at this point in the history
Signed-off-by: Taeik Lim <sibera21@gmail.com>
  • Loading branch information
acktsap committed Apr 2, 2024
1 parent 79f084e commit 6d49ae7
Show file tree
Hide file tree
Showing 6 changed files with 14 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,10 @@ fun <T : Any> ItemStreamSimpleReaderDelegate<T>.asItemStreamReader(): ItemStream
/**
* An extensions to invoke [AdapterFactory.itemStreamReader].
*/
@Deprecated(
message = "Uses ItemStreamFluxReaderDelegate instead",
replaceWith = ReplaceWith(""),
)
fun <T : Any> ItemStreamReaderDelegate<T>.asItemStreamReader(): ItemStreamReader<T> =
AdapterFactory.itemStreamReader(this)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -90,10 +90,12 @@ public static <T> ItemStreamReader<T> itemStreamReader(@NonNull ItemStreamSimple
* Create an adapter which adapt {@link ItemStreamReaderDelegate} to {@link ItemStreamReader}
* with {@link StepScope} bound proxy implementation. It creates new instance for every {@link StepScope}.
*
* @deprecated use {@link #itemStreamReader(ItemStreamFluxReaderDelegate)} instead.
* @param delegate a delegate
* @return an adapted ItemStreamReader
* @param <T> a read item type
*/
@Deprecated
public static <T> ItemStreamReader<T> itemStreamReader(@NonNull ItemStreamReaderDelegate<T> delegate) {
Objects.requireNonNull(delegate, "ItemStreamReader delegate is null");
return StepScopeItemStreamReader.of(() -> ItemStreamReaderAdapter.of(delegate));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,9 @@
* An adapter which adapt {@link ItemStreamReaderDelegate} to {@link ItemStreamReader}.
*
* @since 0.1.0
* @deprecated use {@link ItemStreamFluxReaderAdapter<T>} instead.
*/
@Deprecated
public class ItemStreamReaderAdapter<T> implements ItemStreamReader<T> {

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,9 @@
* A delegate for {@link ItemStreamReader}.
*
* @since 0.1.0
* @deprecated use {@link ItemStreamFluxReaderDelegate<T>} instead.
*/
@Deprecated
public interface ItemStreamReaderDelegate<T> {

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,9 @@
* {@link ItemStreamReader}, {@link ItemProcessor}, {@link ItemStreamWriter} in a single class.
*
* @since 0.1.0
* @deprecated use {@link ItemStreamFluxReaderProcessorWriter<I, O>} instead.
*/
@Deprecated
public interface ItemStreamReaderProcessorWriter<I, O>
extends ItemStreamReaderDelegate<I>, ItemProcessorDelegate<I, O>, ItemStreamWriterDelegate<O> {
}
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,8 @@
* {@link ItemStreamReader}, {@link ItemStreamWriter} in a single class.
*
* @since 0.1.0
* @deprecated use {@link ItemStreamFluxReaderWriter<T>} instead.
*/
@Deprecated
public interface ItemStreamReaderWriter<T> extends ItemStreamReaderDelegate<T>, ItemStreamWriterDelegate<T> {
}

0 comments on commit 6d49ae7

Please sign in to comment.