Add data received logs to SSE and LongPolling in TS client (#484)
This commit is contained in:
parent
d55ebfeee0
commit
a322fea940
|
|
@ -107,6 +107,7 @@ export class ServerSentEventsTransport implements ITransport {
|
||||||
let message;
|
let message;
|
||||||
try {
|
try {
|
||||||
message = Formatters.ServerSentEventsFormat.parse(e.data);
|
message = Formatters.ServerSentEventsFormat.parse(e.data);
|
||||||
|
console.log(`(SSE transport) data received: ${message.content}`);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
if (this.onClosed) {
|
if (this.onClosed) {
|
||||||
this.onClosed(error);
|
this.onClosed(error);
|
||||||
|
|
@ -129,6 +130,7 @@ export class ServerSentEventsTransport implements ITransport {
|
||||||
}
|
}
|
||||||
|
|
||||||
eventSource.onopen = () => {
|
eventSource.onopen = () => {
|
||||||
|
console.log(`SSE connected to ${this.fullUrl}`);
|
||||||
this.eventSource = eventSource;
|
this.eventSource = eventSource;
|
||||||
resolve();
|
resolve();
|
||||||
}
|
}
|
||||||
|
|
@ -197,6 +199,7 @@ export class LongPollingTransport implements ITransport {
|
||||||
}
|
}
|
||||||
|
|
||||||
messages.forEach((message) => {
|
messages.forEach((message) => {
|
||||||
|
console.log(`(LongPolling transport) data received: ${message.content}`);
|
||||||
// TODO: pass the whole message object along
|
// TODO: pass the whole message object along
|
||||||
this.onDataReceived(message.content)
|
this.onDataReceived(message.content)
|
||||||
});
|
});
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue