|
@@ -128,7 +128,8 @@ func (srv *Server) Transport(stream rpcpb.Transport_TransportServer) (err error)
|
|
|
errc := make(chan error)
|
|
errc := make(chan error)
|
|
|
go func() {
|
|
go func() {
|
|
|
for {
|
|
for {
|
|
|
- req, err := stream.Recv()
|
|
|
|
|
|
|
+ var req *rpcpb.Request
|
|
|
|
|
+ req, err = stream.Recv()
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
errc <- err
|
|
errc <- err
|
|
|
// TODO: handle error and retry
|
|
// TODO: handle error and retry
|