lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-10 09:11:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

types: modify Positions to FuturesPositions

Browse Source
This commit is contained in:
austin362667 2021-12-30 21:44:29 +08:00
parent 5cc768031e
commit 3d63032f7d
2 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
pkg/types/standardstream_callbacks.go
View File

@ -124,23 +124,23 @@ func (stream *StandardStream) EmitBookSnapshot(book SliceOrderBook) {
}
}
func (stream *StandardStream) OnPositionUpdate(cb func(position PositionMap)) {
stream.PositionUpdateCallbacks = append(stream.PositionUpdateCallbacks, cb)
func (stream *StandardStream) OnFuturesPositionUpdate(cb func(futuresPositions FuturesPositionMap)) {
stream.FuturesPositionUpdateCallbacks = append(stream.FuturesPositionUpdateCallbacks, cb)
}
func (stream *StandardStream) EmitPositionUpdate(position PositionMap) {
for _, cb := range stream.PositionUpdateCallbacks {
cb(position)
func (stream *StandardStream) EmitFuturesPositionUpdate(futuresPositions FuturesPositionMap) {
for _, cb := range stream.FuturesPositionUpdateCallbacks {
cb(futuresPositions)
}
}
func (stream *StandardStream) OnPositionSnapshot(cb func(position PositionMap)) {
stream.PositionSnapshotCallbacks = append(stream.PositionSnapshotCallbacks, cb)
func (stream *StandardStream) OnFuturesPositionSnapshot(cb func(futuresPositions FuturesPositionMap)) {
stream.FuturesPositionSnapshotCallbacks = append(stream.FuturesPositionSnapshotCallbacks, cb)
}
func (stream *StandardStream) EmitPositionSnapshot(position PositionMap) {
for _, cb := range stream.PositionSnapshotCallbacks {
cb(position)
func (stream *StandardStream) EmitFuturesPositionSnapshot(futuresPositions FuturesPositionMap) {
for _, cb := range stream.FuturesPositionSnapshotCallbacks {
cb(futuresPositions)
}
}
@ -169,7 +169,7 @@ type StandardStreamEventHub interface {
OnBookSnapshot(cb func(book SliceOrderBook))
OnPositionUpdate(cb func(position PositionMap))
OnFuturesPositionUpdate(cb func(futuresPositions FuturesPositionMap))
OnPositionSnapshot(cb func(position PositionMap))
OnFuturesPositionSnapshot(cb func(futuresPositions FuturesPositionMap))
}

4
pkg/types/stream.go
View File

@ -62,9 +62,9 @@ type StandardStream struct {
bookSnapshotCallbacks []func(book SliceOrderBook)
// Futures
PositionUpdateCallbacks []func(position PositionMap)
FuturesPositionUpdateCallbacks []func(futuresPositions FuturesPositionMap)
PositionSnapshotCallbacks []func(position PositionMap)
FuturesPositionSnapshotCallbacks []func(futuresPositions FuturesPositionMap)
}
func (stream *StandardStream) Subscribe(channel Channel, symbol string, options SubscribeOptions) {