chore(): remove old comments
This commit is contained in:
@@ -380,10 +380,6 @@ export class WsStore<
|
|||||||
* @returns
|
* @returns
|
||||||
*/
|
*/
|
||||||
getMatchingTopic(key: WsKey, topic: TWSTopicSubscribeEventArgs) {
|
getMatchingTopic(key: WsKey, topic: TWSTopicSubscribeEventArgs) {
|
||||||
// if (typeof topic === 'string') {
|
|
||||||
// return this.getMatchingTopic(key, { channel: topic });
|
|
||||||
// }
|
|
||||||
|
|
||||||
const allTopics = this.getTopics(key).values();
|
const allTopics = this.getTopics(key).values();
|
||||||
for (const storedTopic of allTopics) {
|
for (const storedTopic of allTopics) {
|
||||||
if (isDeepObjectMatch(topic, storedTopic)) {
|
if (isDeepObjectMatch(topic, storedTopic)) {
|
||||||
@@ -393,13 +389,6 @@ export class WsStore<
|
|||||||
}
|
}
|
||||||
|
|
||||||
addTopic(key: WsKey, topic: TWSTopicSubscribeEventArgs) {
|
addTopic(key: WsKey, topic: TWSTopicSubscribeEventArgs) {
|
||||||
// if (typeof topic === 'string') {
|
|
||||||
// return this.addTopic(key, {
|
|
||||||
// instType: 'sp',
|
|
||||||
// channel: topic,
|
|
||||||
// instId: 'default',
|
|
||||||
// };
|
|
||||||
// }
|
|
||||||
// Check for duplicate topic. If already tracked, don't store this one
|
// Check for duplicate topic. If already tracked, don't store this one
|
||||||
const existingTopic = this.getMatchingTopic(key, topic);
|
const existingTopic = this.getMatchingTopic(key, topic);
|
||||||
if (existingTopic) {
|
if (existingTopic) {
|
||||||
|
|||||||
Reference in New Issue
Block a user