NewSRPCPubSubServiceHandler constructs a new RPC handler.

SRPCRegisterPubSubService registers the implementation with the mux.

IncomingMessage implements Message with a proto object.

OutgoingStatus is status of an outgoing message.

PublishRequest is a message published via the subscribe channel.

SubcribeRequest is a pubsub subscription request message.

SubcribeResponse is a pubsub subscription response message.

SubscripionStatus is the status of the subscription handle.