fix: remove cancel deferred in eventstore

opicaud · Jan 4, 2024 · 46672d2 · 46672d2
1 parent 01113a6
commit 46672d2
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/events/eventstore/grpc/inmemory/pkg/v2beta1/main.go b/events/eventstore/grpc/inmemory/pkg/v2beta1/main.go
@@ -29,7 +29,6 @@ func newInMemoryGrpcEventStore(address string, port int) *InMemoryGrpcEventStore
 type InMemoryGrpcEventStore struct {
  conn *grpc.ClientConn
  client gen.EventStoreClient
- cancel context.CancelFunc
  address string
  err error
  port int
@@ -41,7 +40,6 @@ func (g *InMemoryGrpcEventStore) Connect() *InMemoryGrpcEventStore {
  if g.err != nil {
  log.Panic(g.err)
  }
-
  g.client = gen.NewEventStoreClient(g.conn)
  g.healthIndicator = grpc_health_v1.NewHealthClient(g.conn)
  return g
@@ -54,7 +52,6 @@ func (g *InMemoryGrpcEventStore) deferred() {
  log.Panic(err)
  }
  }(g.conn)
- defer g.cancel()
 }
 
 func (g *InMemoryGrpcEventStore) GetHealthClient(ctx context.Context) (context.Context, grpc_health_v1.HealthClient) {