diff --git a/packages/rsocket-core/src/RSocketMachine.js b/packages/rsocket-core/src/RSocketMachine.js index cee2d3b8..ae545bcc 100644 --- a/packages/rsocket-core/src/RSocketMachine.js +++ b/packages/rsocket-core/src/RSocketMachine.js @@ -888,7 +888,7 @@ class RSocketMachineImpl implements RSocketMachine { flags |= FLAGS.COMPLETE; this._subscriptions.delete(streamId); } - if (metadata !== undefined) { + if (payload.metadata !== undefined) { // eslint-disable-next-line no-bitwise flags |= FLAGS.METADATA; }