apply review comments

Signed-off-by: NikitaSkrynnik <[email protected]>

pkg/networkservice/common/begin/server.go

@@ -31,10 +31,6 @@ import (
 	"github.com/networkservicemesh/sdk/pkg/networkservice/core/next"
 )
 
-const (
-	closeTimeout = time.Minute
-)
-
 type beginServer struct {
 	genericsync.Map[string, *eventFactoryServer]
 	closeTimeout time.Duration
@@ -45,7 +41,7 @@ func NewServer(opts ...Option) networkservice.NetworkServiceServer {
 	o := &option{
 		cancelCtx:    context.Background(),
 		reselect:     false,
-		closeTimeout: closeTimeout,
+		closeTimeout: time.Minute,
 	}
 
 	for _, opt := range opts {

pkg/networkservice/common/begin/server_test.go

@@ -68,6 +68,7 @@ func TestBeginWorksWithSmallTimeout(t *testing.T) {
 	request := testRequest("id")
 	_, err := server.Request(requestCtx, request)
 	require.EqualError(t, err, context.DeadlineExceeded.Error())
+	require.Equal(t, int32(0), waitSrv.requestDone.Load())
 	require.Eventually(t, func() bool {
 		return waitSrv.requestDone.Load() == 1
 	}, waitTime*2, time.Millisecond*500)
@@ -76,6 +77,7 @@ func TestBeginWorksWithSmallTimeout(t *testing.T) {
 	defer cancel()
 	_, err = server.Close(closeCtx, request.Connection)
 	require.EqualError(t, err, context.DeadlineExceeded.Error())
+	require.Equal(t, int32(0), waitSrv.closeDone.Load())
 	require.Eventually(t, func() bool {
 		return waitSrv.closeDone.Load() == 1
 	}, waitTime*2, time.Millisecond*500)