(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
| 470 | } |
| 471 | |
| 472 | func _Plugin_Topic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 473 | in := new(TopicEvent) |
| 474 | if err := dec(in); err != nil { |
| 475 | return nil, err |
| 476 | } |
| 477 | if interceptor == nil { |
| 478 | return srv.(PluginServer).Topic(ctx, in) |
| 479 | } |
| 480 | info := &grpc.UnaryServerInfo{ |
| 481 | Server: srv, |
| 482 | FullMethod: "/pbx.Plugin/Topic", |
| 483 | } |
| 484 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 485 | return srv.(PluginServer).Topic(ctx, req.(*TopicEvent)) |
| 486 | } |
| 487 | return interceptor(ctx, in, info, handler) |
| 488 | } |
| 489 | |
| 490 | func _Plugin_Subscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 491 | in := new(SubscriptionEvent) |
nothing calls this directly
no test coverage detected
searching dependent graphs…