Commit 4f145d10 authored by suyanlong's avatar suyanlong

fixed bug

parent 0b766fc4
Pipeline #8332 canceled with stages
...@@ -81,7 +81,7 @@ func (a *appChain) AsyncSend(msg *pb.Message) error { ...@@ -81,7 +81,7 @@ func (a *appChain) AsyncSend(msg *pb.Message) error {
// ListenIBTPX 监听IBTPX数据。 // ListenIBTPX 监听IBTPX数据。
func (a *appChain) ListenIBTPX() <-chan *pb.Message { func (a *appChain) ListenIBTPX() <-chan *pb.Message {
ibtpCh := a.ListenIBTP() ibtpCh := a.ListenIBTP()
func() { go func() {
for { for {
select { select {
case ibtp := <-ibtpCh: case ibtp := <-ibtpCh:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment