Revised backport version 5.0.11
Issue: SPR-17410 Issue: SPR-17433
This commit is contained in:
@@ -167,7 +167,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
|
||||
* Invoked after an I/O read error from the underlying server or after a
|
||||
* cancellation signal from the downstream consumer to allow sub-classes
|
||||
* to discard any current cached data they might have.
|
||||
* @since 5.1.2
|
||||
* @since 5.0.11
|
||||
*/
|
||||
protected abstract void discardData();
|
||||
|
||||
|
||||
@@ -241,7 +241,7 @@ public abstract class AbstractListenerWriteProcessor<T> implements Processor<T,
|
||||
* to discard in-flight data that was in
|
||||
* the process of being written when the error took place.
|
||||
* @param data the data to be released
|
||||
* @since 5.1.2
|
||||
* @since 5.0.11
|
||||
*/
|
||||
protected abstract void discardData(T data);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user