(self, client: Client, message)
| 561 | return await self.un_watch_channel(symbol, channel, messageHash, 'watchOHLCV', params) |
| 562 | |
| 563 | def handle_ohlcv(self, client: Client, message): |
| 564 | # |
| 565 | # { |
| 566 | # "action": "snapshot", |
| 567 | # "arg": { |
| 568 | # "instType": "SPOT", |
| 569 | # "channel": "candle1m", |
| 570 | # "instId": "BTCUSDT" |
| 571 | # }, |
| 572 | # "data": [ |
| 573 | # [ |
| 574 | # "1701871620000", |
| 575 | # "44080.23", |
| 576 | # "44080.23", |
| 577 | # "44028.5", |
| 578 | # "44028.51", |
| 579 | # "9.9287", |
| 580 | # "437404.105512", |
| 581 | # "437404.105512" |
| 582 | # ], |
| 583 | # [ |
| 584 | # "1701871680000", |
| 585 | # "44028.51", |
| 586 | # "44108.11", |
| 587 | # "44028.5", |
| 588 | # "44108.11", |
| 589 | # "17.139", |
| 590 | # "755436.870643", |
| 591 | # "755436.870643" |
| 592 | # ], |
| 593 | # ], |
| 594 | # "ts": 1701901610417 |
| 595 | # } |
| 596 | # |
| 597 | # uta |
| 598 | # |
| 599 | # { |
| 600 | # "action": "snapshot", |
| 601 | # "arg": { |
| 602 | # "instType": "usdt-futures", |
| 603 | # "topic": "kline", |
| 604 | # "symbol": "BTCUSDT", |
| 605 | # "interval": "1m" |
| 606 | # }, |
| 607 | # "data": [ |
| 608 | # { |
| 609 | # "start": "1755564480000", |
| 610 | # "open": "116286", |
| 611 | # "close": "116256.2", |
| 612 | # "high": "116310.2", |
| 613 | # "low": "116232.8", |
| 614 | # "volume": "39.7062", |
| 615 | # "turnover": "4616746.46654" |
| 616 | # }, |
| 617 | # ], |
| 618 | # "ts": 1755594421877 |
| 619 | # } |
| 620 | # |
no test coverage detected