Skip to content

Commit cdfa824

Browse files
authored
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 <[email protected]> * fix: reference metadata from payload Signed-off-by: Kevin Viglucci <[email protected]> * fix: check for udnefined as well as null in payload.metadata Signed-off-by: Kevin Viglucci <[email protected]>
1 parent 680976a commit cdfa824

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

packages/rsocket-core/src/RSocketMachine.js

+5
Original file line numberDiff line numberDiff line change
@@ -888,6 +888,11 @@ class RSocketMachineImpl<D, M> implements RSocketMachine<D, M> {
888888
flags |= FLAGS.COMPLETE;
889889
this._subscriptions.delete(streamId);
890890
}
891+
if (payload.metadata !== undefined &&
892+
payload.metadata !== null) {
893+
// eslint-disable-next-line no-bitwise
894+
flags |= FLAGS.METADATA;
895+
}
891896
const data = this._serializers.data.serialize(payload.data);
892897
const metadata = this._serializers.metadata.serialize(payload.metadata);
893898
this._connection.sendOne({

0 commit comments

Comments
 (0)