(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
| 506 | } |
| 507 | |
| 508 | func _Plugin_Message_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 509 | in := new(MessageEvent) |
| 510 | if err := dec(in); err != nil { |
| 511 | return nil, err |
| 512 | } |
| 513 | if interceptor == nil { |
| 514 | return srv.(PluginServer).Message(ctx, in) |
| 515 | } |
| 516 | info := &grpc.UnaryServerInfo{ |
| 517 | Server: srv, |
| 518 | FullMethod: "/pbx.Plugin/Message", |
| 519 | } |
| 520 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 521 | return srv.(PluginServer).Message(ctx, req.(*MessageEvent)) |
| 522 | } |
| 523 | return interceptor(ctx, in, info, handler) |
| 524 | } |
| 525 | |
| 526 | // Plugin_ServiceDesc is the grpc.ServiceDesc for Plugin service. |
| 527 | // It's only intended for direct use with grpc.RegisterService, |
nothing calls this directly
no test coverage detected
searching dependent graphs…