in e2e-examples/echo/echo/echo.pb.go [281:294]
func (c *grpcCloudapiClient) EchoStream(ctx context.Context, in *StreamEchoRequest, opts ...grpc.CallOption) (GrpcCloudapi_EchoStreamClient, error) {
stream, err := c.cc.NewStream(ctx, &_GrpcCloudapi_serviceDesc.Streams[0], "/e2e_service.GrpcCloudapi/EchoStream", opts...)
if err != nil {
return nil, err
}
x := &grpcCloudapiEchoStreamClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}