Skip to content

Instantly share code, notes, and snippets.

@neuecc
Created June 21, 2022 11:41
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save neuecc/f5c67a6700c2dee7f2a5a14b7d5afde3 to your computer and use it in GitHub Desktop.
Save neuecc/f5c67a6700c2dee7f2a5a14b7d5afde3 to your computer and use it in GitHub Desktop.
public interface INatsSerializer
{
int Serialize<T>(ICountableBufferWriter bufferWriter, T? value);
T? Deserialize<T>(in ReadOnlySequence<byte> buffer);
}
public interface ICountableBufferWriter : IBufferWriter<byte>
{
int WrittenCount { get; }
}
// ---
// for example, implementation for MessagePack for C#
public class MessagePackNatsSerializer : INatsSerializer
{
public int Serialize<T>(ICountableBufferWriter bufferWriter, T? value)
{
var before = bufferWriter.WrittenCount;
MessagePackSerializer.Serialize(bufferWriter, value);
return bufferWriter.WrittenCount - before;
}
public T? Deserialize<T>(in ReadOnlySequence<byte> buffer)
{
return MessagePackSerializer.Deserialize<T>(buffer);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment