fix: added payload to onPacketreceive and onPacketsend. Fixes #235

sclausen · sclausen · commit 75923af08219 · 2023-07-02T13:01:50.000+02:00
diff --git a/projects/ngx-mqtt/package.json b/projects/ngx-mqtt/package.json
@@ -1,6 +1,6 @@
 {
   "name": "ngx-mqtt",
-  "version": "16.0.0",
+  "version": "16.1.0",
   "license": "MIT",
   "peerDependencies": {
     "@angular/common": "^16.0.3",
diff --git a/projects/ngx-mqtt/src/lib/mqtt.service.ts b/projects/ngx-mqtt/src/lib/mqtt.service.ts
@@ -400,11 +400,11 @@ export class MqttService {
   }
 
   private _handleOnPacketsend = (e: IOnPacketsendEvent) => {
-    this._onPacketsend.emit();
+    this._onPacketsend.emit(e);
   }
 
   private _handleOnPacketreceive = (e: IOnPacketreceiveEvent) => {
-    this._onPacketreceive.emit();
+    this._onPacketreceive.emit(e);
   }
 
   private _generateClientId() {

Original file line number	Diff line number	Diff line change
`@@ -400,11 +400,11 @@ export class MqttService {`
`400`	`400`	`}`
`401`	`401`
`402`	`402`	`private _handleOnPacketsend = (e: IOnPacketsendEvent) => {`
`403`		`- this._onPacketsend.emit();`
	`403`	`+ this._onPacketsend.emit(e);`
`404`	`404`	`}`
`405`	`405`
`406`	`406`	`private _handleOnPacketreceive = (e: IOnPacketreceiveEvent) => {`
`407`		`- this._onPacketreceive.emit();`
	`407`	`+ this._onPacketreceive.emit(e);`
`408`	`408`	`}`
`409`	`409`
`410`	`410`	`private _generateClientId() {`