1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
package test
import (
"context"
)
var (
_ TestingServer = &GrpcTestingServer{}
)
type GrpcTestingServer struct {
UnimplementedTestingServer
UnaryFunc func(context.Context, *Request) (*Response, error)
StreamingFunc func(Testing_StreamingRequestResponseServer) error
}
func (s *GrpcTestingServer) RequestResponse(ctx context.Context, request *Request) (*Response, error) {
return s.UnaryFunc(ctx, request)
}
func (s *GrpcTestingServer) StreamingRequestResponse(server Testing_StreamingRequestResponseServer) error {
return s.StreamingFunc(server)
}
|
