mirror of
https://github.com/wisplite/tether-ts.git
synced 2026-05-01 06:22:41 -05:00
send subscription packets
This commit is contained in:
@@ -34,10 +34,24 @@ export class TetherClient {
|
|||||||
|
|
||||||
subscribe = (query: string, callback: (data: any) => void) => {
|
subscribe = (query: string, callback: (data: any) => void) => {
|
||||||
this.subscribedQueries.set(query, callback);
|
this.subscribedQueries.set(query, callback);
|
||||||
|
if (!this.ws) {
|
||||||
|
throw new Error('Not connected to Tether');
|
||||||
|
}
|
||||||
|
this.ws.send(JSON.stringify({
|
||||||
|
type: 'subscribe',
|
||||||
|
query: query
|
||||||
|
}));
|
||||||
};
|
};
|
||||||
|
|
||||||
unsubscribe = (query: string) => {
|
unsubscribe = (query: string) => {
|
||||||
this.subscribedQueries.delete(query);
|
this.subscribedQueries.delete(query);
|
||||||
|
if (!this.ws) {
|
||||||
|
throw new Error('Not connected to Tether');
|
||||||
|
}
|
||||||
|
this.ws.send(JSON.stringify({
|
||||||
|
type: 'unsubscribe',
|
||||||
|
query: query
|
||||||
|
}));
|
||||||
};
|
};
|
||||||
|
|
||||||
sendMutation = (mutationName: string, params: any) => {
|
sendMutation = (mutationName: string, params: any) => {
|
||||||
|
|||||||
Reference in New Issue
Block a user