33
44import lombok .extern .slf4j .Slf4j ;
55import org .pf4j .PluginWrapper ;
6- import org .pf4j .RuntimeMode ;
7- import org .reactivestreams .Publisher ;
86import org .springframework .stereotype .Component ;
97import reactor .core .Disposable ;
108import reactor .core .publisher .Flux ;
119import reactor .core .publisher .Mono ;
1210import reactor .core .scheduler .Schedulers ;
13- import run .ikaros .api .core .task .TaskOperate ;
1411import run .ikaros .api .plugin .BasePlugin ;
1512
1613import java .time .Duration ;
1714import java .util .Objects ;
18- import java .util .Random ;
1915
2016@ Slf4j
2117@ Component
2218public class Pan115Plugin extends BasePlugin {
23- private Disposable startRefreshTokenTask ;
2419 private final Pan115AttachmentDriverFetcher driverFetcher ;
2520
2621 public Pan115Plugin (PluginWrapper wrapper , Pan115AttachmentDriverFetcher driverFetcher ) {
@@ -30,7 +25,6 @@ public Pan115Plugin(PluginWrapper wrapper, Pan115AttachmentDriverFetcher driverF
3025
3126 @ Override
3227 public void start () {
33- // startRefreshTokenTask = startRefreshTokenTask();
3428 log .info ("plugin [Pan115Plugin] start success" );
3529 }
3630
@@ -47,9 +41,6 @@ private Mono<Void> refreshTokenTask() {
4741
4842 @ Override
4943 public void stop () {
50- if (Objects .nonNull (startRefreshTokenTask )) {
51- startRefreshTokenTask .dispose ();
52- }
5344 log .info ("plugin [Pan115Plugin] stop success" );
5445 }
5546
0 commit comments