wisplite/tether-ts
1
0
Fork 0
mirror of https://github.com/wisplite/tether-ts.git synced 2026-05-01 06:22:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

small update

Browse Source
This commit is contained in:
wisplite
2026-04-21 22:49:23 -05:00
parent 5202a7f844
commit ff47621180
3 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dist/index.d.ts
Vendored
+1 -1
View File
@@ -3,7 +3,7 @@ export declare class TetherClient {
private subscribedQueries; private subscribedQueries;
connect: (url: string) => void; connect: (url: string) => void;
disconnect: () => void; disconnect: () => void;
subscribe: (query: string, callback: (data: any) => void) => void; subscribe: (queryName: string, params: any, callback: (data: any) => void) => void;
unsubscribe: (query: string) => void; unsubscribe: (query: string) => void;
sendMutation: (mutationName: string, params: any) => void; sendMutation: (mutationName: string, params: any) => void;
} }
dist/index.js
Vendored
+5 -4
View File
@@ -14,11 +14,12 @@ export class TetherClient {
disconnect = () => { disconnect = () => {
this.websocketHandler.close(); this.websocketHandler.close();
}; };
subscribe = (query, callback) => { subscribe = (queryName, params, callback) => {
this.subscribedQueries.set(query, callback); this.subscribedQueries.set(queryName, callback);
this.websocketHandler.send(JSON.stringify({ this.websocketHandler.send(JSON.stringify({
type: 'subscribe', type: 'subscribe',
query: query location: queryName,
params: params
})); }));
}; };
unsubscribe = (query) => { unsubscribe = (query) => {
@@ -32,7 +33,7 @@ export class TetherClient {
this.websocketHandler.send(JSON.stringify({ this.websocketHandler.send(JSON.stringify({
type: 'mutation', type: 'mutation',
name: mutationName, name: mutationName,
payload: params, params: params,
})); }));
}; };
} }
src/index.ts
+5 -4
View File
@@ -17,11 +17,12 @@ export class TetherClient {
this.websocketHandler.close(); this.websocketHandler.close();
}; };
subscribe = (query: string, callback: (data: any) => void) => { subscribe = (queryName: string, params: any, callback: (data: any) => void) => {
this.subscribedQueries.set(query, callback); this.subscribedQueries.set(queryName, callback);
this.websocketHandler.send(JSON.stringify({ this.websocketHandler.send(JSON.stringify({
type: 'subscribe', type: 'subscribe',
query: query location: queryName,
params: params
})); }));
}; };
@@ -37,7 +38,7 @@ export class TetherClient {
this.websocketHandler.send(JSON.stringify({ this.websocketHandler.send(JSON.stringify({
type: 'mutation', type: 'mutation',
name: mutationName, name: mutationName,
payload: params, params: params,
})); }));
}; };
} }