github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

Remove underscore from callbacks

Browse Source
This commit is contained in:
Sashko Stubailo
2017-11-09 14:53:11 -08:00
parent af0ecc0aab
commit 78027030e7
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
packages/ddp-client/common/livedata_connection.js
View File

@@ -1618,7 +1618,7 @@ export class Connection {
} else if (msg.msg === 'pong') {
// noop, as we assume everything's a pong
} else if (
_.include(['added', 'changed', 'removed', 'ready', 'updated'], msg.msg)
['added', 'changed', 'removed', 'ready', 'updated'].includes(msg.msg)
) {
this._livedata_data(msg);
} else if (msg.msg === 'nosub') {
@@ -1688,16 +1688,16 @@ export class Connection {
// If the current block of methods all got their results (but didn't all get
// their data visible), discard the empty block now.
if (
!_.isEmpty(this._outstandingMethodBlocks) &&
_.isEmpty(this._outstandingMethodBlocks[0].methods)
this._outstandingMethodBlocks.length > 0 &&
this._outstandingMethodBlocks[0].methods.length === 0
) {
this._outstandingMethodBlocks.shift();
}
// Mark all messages as unsent, they have not yet been sent on this
// connection.
_.each(this._methodInvokers, m => {
m.sentMessage = false;
Object.entries(this._methodInvokers).forEach(([id, methodInvoker]) => {
methodInvoker.sentMessage = false;
});
// If an `onReconnect` handler is set, call it first. Go through
@@ -1709,7 +1709,7 @@ export class Connection {
// add new subscriptions at the end. this way they take effect after
// the handlers and we don't see flicker.
_.each(this._subscriptions, (sub, id) => {
Object.entries(this._subscriptions).forEach(([id, sub]) => {
this._send({
msg: 'sub',
id: id,