From 55c6a435e7fa03dc86366cebc908dbae9f6c091e Mon Sep 17 00:00:00 2001
From: c9s <yoan@maicoin.com>
Date: Thu, 8 Jul 2021 10:13:47 +0800
Subject: [PATCH] binance: remove orderbook convert error var

---
 pkg/exchange/binance/parse.go  | 4 ++--
 pkg/exchange/binance/stream.go | 5 -----
 2 files changed, 2 insertions(+), 7 deletions(-)

diff --git a/pkg/exchange/binance/parse.go b/pkg/exchange/binance/parse.go
index 2d0104a36f..f6d2971a59 100644
--- a/pkg/exchange/binance/parse.go
+++ b/pkg/exchange/binance/parse.go
@@ -503,14 +503,14 @@ func (e *DepthEvent) String() (o string) {
 	return o
 }
 
-func (e *DepthEvent) OrderBook() (book types.SliceOrderBook, err error) {
+func (e *DepthEvent) OrderBook() (book types.SliceOrderBook) {
 	book.Symbol = e.Symbol
 	book.Time = e.EventBase.Time.Time()
 
 	// already in descending order
 	book.Bids = e.Bids
 	book.Asks = e.Asks
-	return book, err
+	return book
 }
 
 func parseDepthEntry(val *fastjson.Value) (*types.PriceVolume, error) {
diff --git a/pkg/exchange/binance/stream.go b/pkg/exchange/binance/stream.go
index bcbc7d71b4..61bfc8a7b2 100644
--- a/pkg/exchange/binance/stream.go
+++ b/pkg/exchange/binance/stream.go
@@ -103,11 +103,6 @@ func NewStream(ex *Exchange, client *binance.Client, futuresClient *futures.Clie
 			})
 			f.SetBufferingPeriod(time.Second)
 			f.OnReady(func(snapshot types.SliceOrderBook, updates []depth.Update) {
-				if valid, err := snapshot.IsValid(); !valid {
-					log.Errorf("%s depth snapshot is invalid, error: %v", e.Symbol, err)
-					return
-				}
-
 				stream.EmitBookSnapshot(snapshot)
 				for _, u := range updates {
 					stream.EmitBookUpdate(u.Object)