diff --git a/mongo.go b/mongo.go index c11f4a4..2a016c9 100644 --- a/mongo.go +++ b/mongo.go @@ -124,7 +124,7 @@ func newMongoClient(ctx context.Context, ci *ConnectionInfo) (MongoClient, error // }() mdb := client.Database(ci.Database, nil) - return MongoClient{c: client, db: mdb}, nil + return MongoClient{c: client, db: mdb, ctx: ctx}, nil } func (mc *MongoClient) Connected() bool {