fix: reference metadata from payload

rsocket · Dec 11, 2021 · 7c1bea9 · 7c1bea9
1 parent 15a0caa
commit 7c1bea9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/packages/rsocket-core/src/RSocketMachine.js b/packages/rsocket-core/src/RSocketMachine.js
@@ -888,7 +888,7 @@ class RSocketMachineImpl<D, M> implements RSocketMachine<D, M> {
       flags |= FLAGS.COMPLETE;
       this._subscriptions.delete(streamId);
     }
-    if (metadata !== undefined) {
+    if (payload.metadata !== undefined) {
       // eslint-disable-next-line no-bitwise
       flags |= FLAGS.METADATA;
     }