unistack-org/micro
3
0
Fork 3
Code Issues 14 Pull Requests 2 Actions Packages Projects Releases 242 Wiki Activity

Merge pull request #1028 from Astone-Chou/fix

Browse Source 
named return value for error defer modify.
This commit is contained in:
Asim Aslam 2019-12-16 15:39:58 +00:00 committed by GitHub
commit 0b59e2ce3d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/grpc/subscriber.go
View File

@ -167,8 +167,7 @@ func validateSubscriber(sub server.Subscriber) error {
}
func (g *grpcServer) createSubHandler(sb *subscriber, opts server.Options) broker.Handler {
return func(p broker.Event) error {
var err error
return func(p broker.Event) (err error) {
defer func() {
if r := recover(); r != nil {

3
server/rpc_router.go
View File

@ -506,8 +506,7 @@ func (router *router) Subscribe(s Subscriber) error {
return nil
}
func (router *router) ProcessMessage(ctx context.Context, msg Message) error {
var err error
func (router *router) ProcessMessage(ctx context.Context, msg Message) (err error) {
defer func() {
// recover any panics

3
transport/grpc/handler.go
View File

@ -16,8 +16,7 @@ type microTransport struct {
fn func(transport.Socket)
}
func (m *microTransport) Stream(ts pb.Transport_StreamServer) error {
var err error
func (m *microTransport) Stream(ts pb.Transport_StreamServer) (err error) {
sock := &grpcTransportSocket{
stream: ts,