Bugfix/26 simulated without data (#33)

* Fixed the bug from issue #26.

Author: marcospds

lib/projects/ngx-sse-client/README.md

@@ -110,6 +110,10 @@ this.sseClient.stream('/subscribe', { responseType: 'text' }).subscribe((data) =
 
 ## CHANGELOG
 
+### 19.0.2
+
+- fixed the issue when `data` of message with any `falsy` value.
+
 ### 19.0.1
 
 - fixed server response ends with non descript error on `keepAlive` _false_.

lib/projects/ngx-sse-client/package.json

@@ -1,6 +1,6 @@
 {
   "name": "ngx-sse-client",
-  "version": "19.0.1",
+  "version": "19.0.2",
   "description": "A simple SSE (Server Sent Events) client for Angular applications.",
   "keywords": [
     "angular",

lib/projects/ngx-sse-client/src/lib/sse-client-subscriber.ts

@@ -69,6 +69,7 @@ export class SseClientSubscriber {
   }
 
   private onStreamProgress(data: string, observer: Subscriber<string>): void {
+    if(!data) return;
     data = data.substring(this.progress);
     this.progress += data.length;
     data.split(/(\r\n|\r|\n){2}/g).forEach((part) => this.parseEventData(part, observer));

server/server.js

@@ -26,6 +26,7 @@ app.get('/subscribe', (req, res) => {
   res.header('Access-Control-Allow-Origin', '*');
   res.on('close', () => removeEmitters([emitter]));
   res.flushHeaders();
+  res.write(`${END_CONTENT}`);
 
   emitters.push(emitter);
   console.info(`SUBSCRIBED ID ${emitter.id}`);