Update base_service.go

andot · web-flow · commit d19fb7ecb6e2 · 2017-08-18T16:21:16.000+08:00
Fixed service timeout stop subscribe.
diff --git a/rpc/base_service.go b/rpc/base_service.go
@@ -596,7 +596,6 @@ func (service *BaseService) Publish(
 		case result := <-message:
 			return result
 		case <-time.After(timeout):
-			service.offline(t, topic, id)
 			return nil
 		}
 	}, Options{})

Original file line number	Diff line number	Diff line change
`@@ -596,7 +596,6 @@ func (service *BaseService) Publish(`
`596`	`596`	`case result := <-message:`
`597`	`597`	`return result`
`598`	`598`	`case <-time.After(timeout):`
`599`		`- service.offline(t, topic, id)`
`600`	`599`	`return nil`
`601`	`600`	`}`
`602`	`601`	`}, Options{})`