const subscription = client
.from("agent_query")
.on("*", (payload) => {
console.log("got a payload", payload); //never triggers
}).subscribe();
console.log("initial state", subscription.state); //prints joining
subscription.onError(() => {
console.log("error!"); // never triggers
});
subscription.onClose(() => {
console.log("closed!"); //never triggers
});
subscription.onMessage(() => {
console.log("message!"); // never triggers
});
setInterval(() => {
console.log(subscription.state); // always prints "joined", so it succesfully joined but gets no messages
}, 2000);
const subscription = client
.from("agent_query")
.on("*", (payload) => {
console.log("got a payload", payload); //never triggers
}).subscribe();
console.log("initial state", subscription.state); //prints joining
subscription.onError(() => {
console.log("error!"); // never triggers
});
subscription.onClose(() => {
console.log("closed!"); //never triggers
});
subscription.onMessage(() => {
console.log("message!"); // never triggers
});
setInterval(() => {
console.log(subscription.state); // always prints "joined", so it succesfully joined but gets no messages
}, 2000);