From db7e4a82772484e7981206a509b871ec41afcbc6 Mon Sep 17 00:00:00 2001 From: Ishan Taldekar Date: Fri, 24 Jan 2025 17:30:12 -0500 Subject: [PATCH] Remove subscription and type introspection --- .../eclipse/amazonq/lsp/auth/AuthSourceProvider.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/plugin/src/software/aws/toolkits/eclipse/amazonq/lsp/auth/AuthSourceProvider.java b/plugin/src/software/aws/toolkits/eclipse/amazonq/lsp/auth/AuthSourceProvider.java index e3ed903c..604c460e 100644 --- a/plugin/src/software/aws/toolkits/eclipse/amazonq/lsp/auth/AuthSourceProvider.java +++ b/plugin/src/software/aws/toolkits/eclipse/amazonq/lsp/auth/AuthSourceProvider.java @@ -13,8 +13,8 @@ import org.eclipse.ui.PlatformUI; import org.eclipse.ui.services.ISourceProviderService; +import io.reactivex.rxjava3.disposables.Disposable; import software.aws.toolkits.eclipse.amazonq.broker.api.EventObserver; -import software.aws.toolkits.eclipse.amazonq.broker.api.Subscription; import software.aws.toolkits.eclipse.amazonq.lsp.auth.model.AuthState; import software.aws.toolkits.eclipse.amazonq.plugin.Activator; @@ -35,10 +35,10 @@ public final class AuthSourceProvider extends AbstractSourceProvider implements EventObserver { public static final String IS_LOGGED_IN_VARIABLE_ID = "is_logged_in"; private boolean isLoggedIn = false; - private Subscription authStateSubscription; + private Disposable authStateSubscription; public AuthSourceProvider() { - authStateSubscription = Activator.getEventBroker().subscribe(this); + authStateSubscription = Activator.getEventBroker().subscribe(AuthState.class, this); isLoggedIn = Activator.getLoginService().getAuthState().isLoggedIn(); } @@ -57,7 +57,7 @@ public void dispose() { // Notify listeners that this provider is being disposed fireSourceChanged(ISources.WORKBENCH, IS_LOGGED_IN_VARIABLE_ID, null); - authStateSubscription.cancel(); + authStateSubscription.dispose(); } @Override