mobile: fixed PR review notes

This commit is contained in:
Eugene Valeyev 2018-03-22 15:54:11 +03:00
parent ef315b51ec
commit 58272192c9
3 changed files with 7 additions and 7 deletions

View file

@ -137,8 +137,8 @@ func (ec *EthereumClient) SubscribeNewHead(ctx *Context, handler NewHeadHandler,
case header := <-ch: case header := <-ch:
handler.OnNewHead(&Header{header}) handler.OnNewHead(&Header{header})
case err, ok := <-rawSub.Err(): case err := <-rawSub.Err():
if ok { if err != nil {
handler.OnError(err.Error()) handler.OnError(err.Error())
} }
return return
@ -228,8 +228,8 @@ func (ec *EthereumClient) SubscribeFilterLogs(ctx *Context, query *FilterQuery,
case log := <-ch: case log := <-ch:
handler.OnFilterLogs(&Log{&log}) handler.OnFilterLogs(&Log{&log})
case err, ok := <-rawSub.Err(): case err := <-rawSub.Err():
if ok { if err != nil {
handler.OnError(err.Error()) handler.OnError(err.Error())
} }
return return

View file

@ -160,8 +160,8 @@ func (wc *WhisperClient) SubscribeMessages(ctx *Context, criteria *Criteria, han
case message := <-ch: case message := <-ch:
handler.OnNewMessage(&Message{message}) handler.OnNewMessage(&Message{message})
case err, ok := <-rawSub.Err(): case err := <-rawSub.Err():
if ok { if err != nil {
handler.OnError(err.Error()) handler.OnError(err.Error())
} }
return return

View file

@ -1,5 +1,5 @@
// Copyright (c) 2012 The Go Authors. All rights reserved. // Copyright (c) 2012 The Go Authors. All rights reserved.
// //
// Redistribution and use in source and binary forms, with or without // Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions are // modification, are permitted provided that the following conditions are
// met: // met: