diff --git a/libs/pubsub/pubsub.go b/libs/pubsub/pubsub.go index fd4a2693..9ad63430 100644 --- a/libs/pubsub/pubsub.go +++ b/libs/pubsub/pubsub.go @@ -13,10 +13,10 @@ // Example: // // q, err := query.New("account.name='John'") -// if err != nil { -// return err -// } -// ctx, cancel := context.WithTimeout(context.Background(), 1 * time.Second) +// if err != nil { +// return err +// } +// ctx, cancel := context.WithTimeout(context.Background(), 1 * time.Second) // defer cancel() // subscription, err := pubsub.Subscribe(ctx, "johns-transactions", q) // if err != nil { @@ -25,12 +25,12 @@ // // for { // select { -// case msg <- subscription.Out(): -// // handle msg.Data() and msg.Tags() -// case <-subscription.Cancelled(): -// return subscription.Err() -// } -// } +// case msg <- subscription.Out(): +// // handle msg.Data() and msg.Tags() +// case <-subscription.Cancelled(): +// return subscription.Err() +// } +// } // package pubsub