bridge/github/import_mediator.go 🔗
@@ -89,6 +89,7 @@ func NewImportMediator(ctx context.Context, client *rateLimitHandlerClient, owne
}
go func() {
mm.fillImportEvents(ctx)
+ ctx.Done()
close(mm.importEvents)
}()
return &mm
Steve Moyer created
bridge/github/import_mediator.go | 1 +
1 file changed, 1 insertion(+)
@@ -89,6 +89,7 @@ func NewImportMediator(ctx context.Context, client *rateLimitHandlerClient, owne
}
go func() {
mm.fillImportEvents(ctx)
+ ctx.Done()
close(mm.importEvents)
}()
return &mm