mirror of
https://github.com/taigrr/nats.docs
synced 2025-01-18 04:03:23 -08:00
Merge pull request #58 from GingerMoon/patch-2
flush wrongly used in the sample code
This commit is contained in:
commit
e9dee4367f
@ -119,10 +119,10 @@ sub, err := nc.SubscribeSync(replyTo)
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
nc.Flush()
|
|
||||||
|
|
||||||
// Send the request
|
// Send the request immediately
|
||||||
nc.PublishRequest(subject, replyTo, []byte(input))
|
nc.PublishRequest(subject, replyTo, []byte(input))
|
||||||
|
nc.Flush()
|
||||||
|
|
||||||
// Wait for a single response
|
// Wait for a single response
|
||||||
for {
|
for {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user