From cdfa824513ae58c5ef8abb14c3754c99199296b8 Mon Sep 17 00:00:00 2001
From: Kevin Viglucci <kviglucci@gmail.com>
Date: Wed, 5 Jan 2022 16:02:56 -0600
Subject: [PATCH] fix: add Metadata flag when sending stream payload which has
 metadata (#200)

* fix: add Metadata flag when sending stream payload which has metadata

Signed-off-by: Kevin Viglucci <kviglucci@gmail.com>

* fix: reference metadata from payload

Signed-off-by: Kevin Viglucci <kviglucci@gmail.com>

* fix: check for udnefined as well as null in payload.metadata

Signed-off-by: Kevin Viglucci <kviglucci@gmail.com>
---
 packages/rsocket-core/src/RSocketMachine.js | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/packages/rsocket-core/src/RSocketMachine.js b/packages/rsocket-core/src/RSocketMachine.js
index 63f2554c..02bbb3cc 100644
--- a/packages/rsocket-core/src/RSocketMachine.js
+++ b/packages/rsocket-core/src/RSocketMachine.js
@@ -888,6 +888,11 @@ class RSocketMachineImpl<D, M> implements RSocketMachine<D, M> {
       flags |= FLAGS.COMPLETE;
       this._subscriptions.delete(streamId);
     }
+    if (payload.metadata !== undefined &&
+        payload.metadata !== null) {
+      // eslint-disable-next-line no-bitwise
+      flags |= FLAGS.METADATA;
+    }
     const data = this._serializers.data.serialize(payload.data);
     const metadata = this._serializers.metadata.serialize(payload.metadata);
     this._connection.sendOne({