Skip to content

Commit

Permalink
Fix conflicts.
Browse files Browse the repository at this point in the history
  • Loading branch information
vincentwschau committed May 9, 2024
1 parent 38b00fb commit e679a79
Showing 1 changed file with 1 addition and 15 deletions.
16 changes: 1 addition & 15 deletions indexer/services/socks/src/lib/message-forwarder.ts
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ import {
import { Index } from '../websocket/index';
import { MAX_TIMEOUT_INTEGER } from './constants';
import { Subscriptions } from './subscription';
import { STATS_NO_SAMPLING } from '@dydxprotocol-indexer/base';

const BATCH_SEND_INTERVAL_MS: number = config.BATCH_SEND_INTERVAL_MS;
const BUFFER_KEY_SEPARATOR: string = ':';
Expand Down Expand Up @@ -127,20 +128,6 @@ export class MessageForwarder {
return;
}

<<<<<<< HEAD
const start: number = Date.now();
this.forwardMessage(messageToForward);
const end: number = Date.now();
stats.timing(
`${config.SERVICE_NAME}.forward_message`,
end - start,
config.MESSAGE_FORWARDER_STATSD_SAMPLE_RATE,
{
topic,
channel: String(channel),
},
);
=======
const startForwardMessage: number = Date.now();
this.forwardMessage(messageToForward);
const end: number = Date.now();
Expand All @@ -167,7 +154,6 @@ export class MessageForwarder {
);
}
}
>>>>>>> 355d9e9b ([TRA-109] Add parent subaccount websocket (#1463))
}

public forwardMessage(message: MessageToForward): void {
Expand Down

0 comments on commit e679a79

Please sign in to comment.