fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-06-06 10:01:19 +00:00
Code Issues Projects Releases Wiki Activity

fix formatting

Browse Source
This commit is contained in:
Anton Kaliaev 2019-02-03 15:49:19 +04:00
parent 6464bcba7d
commit c6e3059e32
No known key found for this signature in database
GPG Key ID: 7B6881D965918214
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
libs/pubsub/pubsub.go
View File

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