NewMuxService creates a new multiplexing service and registers it to rpc server.
(serviceName string, server *rpc.Server)
| 31 | |
| 32 | // NewMuxService creates a new multiplexing service and registers it to rpc server. |
| 33 | func NewMuxService(serviceName string, server *rpc.Server) (service *MuxService, err error) { |
| 34 | service = &MuxService{ |
| 35 | ServiceName: serviceName, |
| 36 | } |
| 37 | |
| 38 | err = server.RegisterService(serviceName, service) |
| 39 | return |
| 40 | } |
| 41 | |
| 42 | func (s *MuxService) register(id proto.DatabaseID, service *ChainRPCService) { |
| 43 | s.serviceMap.Store(id, service) |