Skip to content

Commit a4e2bee

Browse files
committedFeb 27, 2025
chore: add onConnect/onDisconnect hook inside baseCloudClient
1 parent 23d26ea commit a4e2bee

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed
 

‎src/builder/IArduinoIoTCloudFactory.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,6 @@ export type CloudFactoryOptions = (APIOptions | CredentialsOptions | BrowserOpti
88

99
export interface IArduinoIoTCloudFactory {
1010
connect(options: APIOptions & Partial<CloudOptions>): Promise<IMultiPropertiesCloudClient>;
11-
connect(options: CredentialsOptions & Partial<CloudOptions>): Promise<ISinglePropertyCloudClient>;
1211
connect(options: BrowserOptions & Partial<CloudOptions>): Promise<IMultiPropertiesCloudClient>;
12+
connect(options: CredentialsOptions & Partial<CloudOptions>): Promise<ISinglePropertyCloudClient>;
1313
}

‎src/client/BaseCloudClient.ts

+2
Original file line numberDiff line numberDiff line change
@@ -63,12 +63,14 @@ export class BaseCloudClient<T extends IConnection = IConnection> implements ICl
6363
if (err) throw new Error(`subscription failed: ${err.toString()}`);
6464

6565
subscription = this.connection.messages.pipe(filter((v) => v.topic === topic)).subscribe((v) => subject.next(v));
66+
this.options.onConnected();
6667
});
6768

6869
const originalMethod = subject.unsubscribe;
6970
subject.unsubscribe = () => {
7071
subscription.unsubscribe();
7172
originalMethod();
73+
this.options.onDisconnect();
7274
};
7375

7476
return subject;

0 commit comments

Comments
 (0)
Please sign in to comment.