rename trade callbacks to trade update callbacks

c9s · Oct 31, 2020 · 74a9cae · 74a9cae
1 parent 224acd0
commit 74a9cae
Show file tree

Hide file tree

Showing 3 changed files with 29 additions and 9 deletions.
diff --git a/pkg/types/orderbook.go b/pkg/types/orderbook.go
@@ -40,6 +40,13 @@ func (slice PriceVolumeSlice) Copy() PriceVolumeSlice {
 	return append(slice[:0:0], slice...)
 }
 
+func (slice PriceVolumeSlice) First() (PriceVolume, bool) {
+	if len(slice) > 0 {
+		return slice[0], true
+	}
+	return PriceVolume{}, false
+}
+
 func (slice PriceVolumeSlice) IndexByVolumeDepth(requiredVolume fixedpoint.Value) int {
 	var tv int64 = 0
 	for x, el := range slice {

diff --git a/pkg/types/standardstream_callbacks.go b/pkg/types/standardstream_callbacks.go
diff --git a/pkg/types/stream.go b/pkg/types/stream.go
@@ -22,8 +22,11 @@ var KLineChannel = Channel("kline")
 type StandardStream struct {
 	Subscriptions []Subscription
 
-	// private trade callbacks
-	tradeCallbacks []func(trade Trade)
+	// private trade update callbacks
+	tradeUpdateCallbacks []func(trade Trade)
+
+	// private order update callbacks
+	orderUpdateCallbacks []func(order Order)
 
 	// balance snapshot callbacks
 	balanceSnapshotCallbacks []func(balances map[string]Balance)