Event subscription helper/tools

[bounoable]

Wait for a single event to be published, then cancel the subscription

• [x] Done

package example

func example(ctx context.Context, bus event.Bus) {
    evt, errs, err := eventbus.Await(ctx, bus, "foo-evt")
    if err != nil {
        panic(err)
    }

    select {
    case <-ctx.Done():
        panic(ctx.Error())
    case err := <-errs:
        panic(err)
    case e := <-evt:
        log.Println(e)
    }
}