@aws-sdk/eventstream-marshaller

Serialize Event Stream

This feature allows you to serialize an event stream. The code sample demonstrates how to create an instance of EventStreamMarshaller and use it to serialize an event.

const { EventStreamMarshaller } = require('@aws-sdk/eventstream-marshaller');
const { TextEncoder } = require('util');

const marshaller = new EventStreamMarshaller(new TextEncoder(), new TextDecoder());
const event = { headers: {}, body: Buffer.from('example data') };
const serialized = marshaller.marshall(event);
console.log(serialized);

Deserialize Event Stream

This feature allows you to deserialize an event stream. The code sample demonstrates how to create an instance of EventStreamMarshaller and use it to deserialize an event.

const { EventStreamMarshaller } = require('@aws-sdk/eventstream-marshaller');
const { TextDecoder } = require('util');

const marshaller = new EventStreamMarshaller(new TextEncoder(), new TextDecoder());
const serialized = Buffer.from('example serialized data');
const event = marshaller.unmarshall(serialized);
console.log(event);