zeromq / netmq

A 100% native C# implementation of ZeroMQ for .NET
Other
2.95k stars 744 forks source link

Last Value Cache implementation. #939

Closed Svisstack closed 3 years ago

Svisstack commented 4 years ago

Hi,

I'm considering implementing extended implementation of Last Value Cache, when the new Subscriber attaching subscription (all or specific topics) then based on that I deliver some data (lets call it welcome message).

Looking at internal class XPub : SocketBase and it seems that this will require changes in this internal class. This could be done using another class by inheritance?

My current understanding is that the XPub should be public and there will be a virtual function implemented that could inject arbitrary data based on the subscription scope into the pipe as the first message before the subscription is hooked.