Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewServerConnectionPublisherProxy ¶
func NewServerConnectionPublisherProxy(exe actor.EnqueueActor, upstream sconn.ServerConnectionPublisher, logger log.Logger) sconn.ServerConnectionPublisher
This assumes that AddServerConnectionSubscriber and RemoveServerConnectionSubscriber will always be run from exe's thread. This uses exe to process calls from ConnectedRMs, ConnectionLost and ConnectionEstablished, invoked by the upstream.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.