Method ReceiveContext

pkg/events/handler.go:64–71

ReceiveContext returns the next event from the channel or returns nil when the context is done.

(ctx context.Context)

// ReceiveContext returns the next event from the channel or returns nil when the context is done.
func (ch Channel) ReceiveContext(ctx context.Context) Event {
	select {
	case evt := <-ch:
		return evt
	case <-ctx.Done():
		return nil
	}
}

// ContextHandler delivers events to the Handler as long as ctx.Err() is non-nil.
func ContextHandler(ctx context.Context, handler Handler) Handler {