File tree 3 files changed +5
-9
lines changed
framework-docs/modules/ROOT/pages/integration
main/java/org/springframework/scheduling/annotation
test/java/org/springframework/scheduling/annotation
3 files changed +5
-9
lines changed Original file line number Diff line number Diff line change @@ -499,10 +499,9 @@ seconds:
499
499
[NOTE]
500
500
====
501
501
When destroying the annotated bean or closing the application context Spring Framework cancels
502
- scheduled tasks, which includes the next scheduled subscription to the `Publisher`.
503
- However, there is no tracking of individual subscriptions: once a subscription has started
504
- it can't be cancelled. For that reason, it is a pre-requisite that the `Publisher` is finite
505
- in addition to supporting multiple subsequent subscriptions.
502
+ scheduled tasks, which includes the next scheduled subscription to the `Publisher` as well
503
+ as any past subscription that is still currently active (e.g. for long-running publishers,
504
+ or even infinite publishers).
506
505
====
507
506
508
507
Original file line number Diff line number Diff line change 38
38
*
39
39
* <p>Methods that return a reactive {@code Publisher} or a type which can be adapted
40
40
* to {@code Publisher} by the default {@code ReactiveAdapterRegistry} are supported.
41
- * The {@code Publisher} MUST be finite and MUST support multiple subsequent subscriptions
42
- * (i.e. be cold).
41
+ * The {@code Publisher} MUST support multiple subsequent subscriptions (i.e. be cold).
43
42
* The returned Publisher is only produced once, and the scheduling infrastructure
44
43
* then periodically {@code subscribe()} to it according to configuration.
45
44
* Values emitted by the publisher are ignored. Errors are logged at WARN level, which
Original file line number Diff line number Diff line change @@ -99,9 +99,7 @@ void rejectCantAccessMethod() {
99
99
.withCause (new IllegalAccessException ("expected" ));
100
100
}
101
101
102
- //FIXME find a way to test the case with fixedDelay effectively turning into a fixedRate ?
103
-
104
- //FIXME test createCheckpointPublisherFor uses Reactor and checkpoint operator
102
+ //TODO find a way to test the case with fixedDelay effectively turning into a fixedRate ?
105
103
106
104
@ Test
107
105
void hasCheckpointToString () {
You can’t perform that action at this time.
0 commit comments