| deliver @ 8e158e | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| main.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
deliver
@@ -1 +1 @@ Subproject commit a6b23c5eaf5a8b9265e13d3db370d45cfcd5bc21 Subproject commit 8e158e611ca6a3663e383d5a9b14d14eaf897736 main.go
@@ -35,7 +35,7 @@ } func sender(url string, args ...interface{}) { s := deliver.NewProducer(deliver.Mode(mode), url, args...) s := deliver.NewListener(deliver.Mode(mode), url, args...) go senderImpl(s) @@ -47,7 +47,7 @@ } func recvImpl(url string, index int) { c := deliver.NewConsumer(deliver.Mode(mode), url) c := deliver.NewDialer(deliver.Mode(mode), url) var msg []byte var err error
