Method start

bridge/github/import_mediator.go:60–67

(ctx context.Context)

}

func (mm *importMediator) start(ctx context.Context) {
	ctx, cancel := context.WithCancel(ctx)
	mm.fillImportEvents(ctx)
	// Make sure we cancel everything when we are done, instead of relying on the parent context
	// This should unblock pending send to the channel if the capacity was reached and avoid a panic/race when closing.
	cancel()
	close(mm.importEvents)
}

// NextImportEvent returns the next ImportEvent, or nil if done.
func (mm *importMediator) NextImportEvent() ImportEvent {