(serverImpl ServerImpl)
| 202 | } |
| 203 | |
| 204 | func validateServerImpl(serverImpl ServerImpl) { |
| 205 | if serverImpl == nil { |
| 206 | return |
| 207 | } |
| 208 | serverType := reflect.TypeOf(serverImpl) |
| 209 | if serverType.Kind() != reflect.Pointer && serverType.Elem().Kind() != reflect.Struct { |
| 210 | panic(fmt.Sprintf("serverImpl must be a pointer to struct, got %v", serverType)) |
| 211 | } |
| 212 | } |
| 213 | |
| 214 | // closes outputCh when inputCh is closed/done |
| 215 | func MakeWshRpcWithChannels(inputCh chan baseds.RpcInputChType, outputCh chan []byte, rpcCtx wshrpc.RpcContext, serverImpl ServerImpl, debugName string) *WshRpc { |
no outgoing calls
no test coverage detected