Index: src/object-observe.js |
diff --git a/src/object-observe.js b/src/object-observe.js |
deleted file mode 100644 |
index 80296586d214093751c38aa661d34a7280d0bd7b..0000000000000000000000000000000000000000 |
--- a/src/object-observe.js |
+++ /dev/null |
@@ -1,720 +0,0 @@ |
-// Copyright 2012 the V8 project authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-var $observeEnqueueSpliceRecord; |
-var $observeBeginPerformSplice; |
-var $observeEndPerformSplice; |
- |
-var $observeObjectMethods; |
-var $observeArrayMethods; |
- |
-(function(global, utils) { |
- |
-"use strict"; |
- |
-%CheckIsBootstrapping(); |
- |
-// ------------------------------------------------------------------- |
-// Imports |
- |
-var GlobalArray = global.Array; |
-var GlobalObject = global.Object; |
-var InternalArray = utils.InternalArray; |
- |
-var ObjectFreeze; |
-var ObjectIsFrozen; |
- |
-utils.Import(function(from) { |
- ObjectFreeze = from.ObjectFreeze; |
- ObjectIsFrozen = from.ObjectIsFrozen; |
-}); |
- |
-// ------------------------------------------------------------------- |
- |
-// Overview: |
-// |
-// This file contains all of the routing and accounting for Object.observe. |
-// User code will interact with these mechanisms via the Object.observe APIs |
-// and, as a side effect of mutation objects which are observed. The V8 runtime |
-// (both C++ and JS) will interact with these mechanisms primarily by enqueuing |
-// proper change records for objects which were mutated. The Object.observe |
-// routing and accounting consists primarily of three participants |
-// |
-// 1) ObjectInfo. This represents the observed state of a given object. It |
-// records what callbacks are observing the object, with what options, and |
-// what "change types" are in progress on the object (i.e. via |
-// notifier.performChange). |
-// |
-// 2) CallbackInfo. This represents a callback used for observation. It holds |
-// the records which must be delivered to the callback, as well as the global |
-// priority of the callback (which determines delivery order between |
-// callbacks). |
-// |
-// 3) observationState.pendingObservers. This is the set of observers which |
-// have change records which must be delivered. During "normal" delivery |
-// (i.e. not Object.deliverChangeRecords), this is the mechanism by which |
-// callbacks are invoked in the proper order until there are no more |
-// change records pending to a callback. |
-// |
-// Note that in order to reduce allocation and processing costs, the |
-// implementation of (1) and (2) have "optimized" states which represent |
-// common cases which can be handled more efficiently. |
- |
-var observationState; |
- |
-var notifierPrototype = {}; |
- |
-// We have to wait until after bootstrapping to grab a reference to the |
-// observationState object, since it's not possible to serialize that |
-// reference into the snapshot. |
-function GetObservationStateJS() { |
- if (IS_UNDEFINED(observationState)) { |
- observationState = %GetObservationState(); |
- } |
- |
- // TODO(adamk): Consider moving this code into heap.cc |
- if (IS_UNDEFINED(observationState.callbackInfoMap)) { |
- observationState.callbackInfoMap = %ObservationWeakMapCreate(); |
- observationState.objectInfoMap = %ObservationWeakMapCreate(); |
- observationState.notifierObjectInfoMap = %ObservationWeakMapCreate(); |
- observationState.pendingObservers = null; |
- observationState.nextCallbackPriority = 0; |
- observationState.lastMicrotaskId = 0; |
- } |
- |
- return observationState; |
-} |
- |
- |
-function GetPendingObservers() { |
- return GetObservationStateJS().pendingObservers; |
-} |
- |
- |
-function SetPendingObservers(pendingObservers) { |
- GetObservationStateJS().pendingObservers = pendingObservers; |
-} |
- |
- |
-function GetNextCallbackPriority() { |
- return GetObservationStateJS().nextCallbackPriority++; |
-} |
- |
- |
-function nullProtoObject() { |
- return { __proto__: null }; |
-} |
- |
- |
-function TypeMapCreate() { |
- return nullProtoObject(); |
-} |
- |
- |
-function TypeMapAddType(typeMap, type, ignoreDuplicate) { |
- typeMap[type] = ignoreDuplicate ? 1 : (typeMap[type] || 0) + 1; |
-} |
- |
- |
-function TypeMapRemoveType(typeMap, type) { |
- typeMap[type]--; |
-} |
- |
- |
-function TypeMapCreateFromList(typeList, length) { |
- var typeMap = TypeMapCreate(); |
- for (var i = 0; i < length; i++) { |
- TypeMapAddType(typeMap, typeList[i], true); |
- } |
- return typeMap; |
-} |
- |
- |
-function TypeMapHasType(typeMap, type) { |
- return !!typeMap[type]; |
-} |
- |
- |
-function TypeMapIsDisjointFrom(typeMap1, typeMap2) { |
- if (!typeMap1 || !typeMap2) |
- return true; |
- |
- for (var type in typeMap1) { |
- if (TypeMapHasType(typeMap1, type) && TypeMapHasType(typeMap2, type)) |
- return false; |
- } |
- |
- return true; |
-} |
- |
- |
-var defaultAcceptTypes = (function() { |
- var defaultTypes = [ |
- 'add', |
- 'update', |
- 'delete', |
- 'setPrototype', |
- 'reconfigure', |
- 'preventExtensions' |
- ]; |
- return TypeMapCreateFromList(defaultTypes, defaultTypes.length); |
-})(); |
- |
- |
-// An Observer is a registration to observe an object by a callback with |
-// a given set of accept types. If the set of accept types is the default |
-// set for Object.observe, the observer is represented as a direct reference |
-// to the callback. An observer never changes its accept types and thus never |
-// needs to "normalize". |
-function ObserverCreate(callback, acceptList) { |
- if (IS_UNDEFINED(acceptList)) |
- return callback; |
- var observer = nullProtoObject(); |
- observer.callback = callback; |
- observer.accept = acceptList; |
- return observer; |
-} |
- |
- |
-function ObserverGetCallback(observer) { |
- return IS_CALLABLE(observer) ? observer : observer.callback; |
-} |
- |
- |
-function ObserverGetAcceptTypes(observer) { |
- return IS_CALLABLE(observer) ? defaultAcceptTypes : observer.accept; |
-} |
- |
- |
-function ObserverIsActive(observer, objectInfo) { |
- return TypeMapIsDisjointFrom(ObjectInfoGetPerformingTypes(objectInfo), |
- ObserverGetAcceptTypes(observer)); |
-} |
- |
- |
-function ObjectInfoGetOrCreate(object) { |
- var objectInfo = ObjectInfoGet(object); |
- if (IS_UNDEFINED(objectInfo)) { |
- if (!%_IsJSProxy(object)) { |
- %SetIsObserved(object); |
- } |
- objectInfo = { |
- object: object, |
- changeObservers: null, |
- notifier: null, |
- performing: null, |
- performingCount: 0, |
- }; |
- %WeakCollectionSet(GetObservationStateJS().objectInfoMap, |
- object, objectInfo, $getHash(object)); |
- } |
- return objectInfo; |
-} |
- |
- |
-function ObjectInfoGet(object) { |
- return %WeakCollectionGet(GetObservationStateJS().objectInfoMap, object, |
- $getHash(object)); |
-} |
- |
- |
-function ObjectInfoGetFromNotifier(notifier) { |
- return %WeakCollectionGet(GetObservationStateJS().notifierObjectInfoMap, |
- notifier, $getHash(notifier)); |
-} |
- |
- |
-function ObjectInfoGetNotifier(objectInfo) { |
- if (IS_NULL(objectInfo.notifier)) { |
- var notifier = { __proto__: notifierPrototype }; |
- objectInfo.notifier = notifier; |
- %WeakCollectionSet(GetObservationStateJS().notifierObjectInfoMap, |
- notifier, objectInfo, $getHash(notifier)); |
- } |
- |
- return objectInfo.notifier; |
-} |
- |
- |
-function ChangeObserversIsOptimized(changeObservers) { |
- return IS_CALLABLE(changeObservers) || |
- IS_CALLABLE(changeObservers.callback); |
-} |
- |
- |
-// The set of observers on an object is called 'changeObservers'. The first |
-// observer is referenced directly via objectInfo.changeObservers. When a second |
-// is added, changeObservers "normalizes" to become a mapping of callback |
-// priority -> observer and is then stored on objectInfo.changeObservers. |
-function ObjectInfoNormalizeChangeObservers(objectInfo) { |
- if (ChangeObserversIsOptimized(objectInfo.changeObservers)) { |
- var observer = objectInfo.changeObservers; |
- var callback = ObserverGetCallback(observer); |
- var callbackInfo = CallbackInfoGet(callback); |
- var priority = CallbackInfoGetPriority(callbackInfo); |
- objectInfo.changeObservers = nullProtoObject(); |
- objectInfo.changeObservers[priority] = observer; |
- } |
-} |
- |
- |
-function ObjectInfoAddObserver(objectInfo, callback, acceptList) { |
- var callbackInfo = CallbackInfoGetOrCreate(callback); |
- var observer = ObserverCreate(callback, acceptList); |
- |
- if (!objectInfo.changeObservers) { |
- objectInfo.changeObservers = observer; |
- return; |
- } |
- |
- ObjectInfoNormalizeChangeObservers(objectInfo); |
- var priority = CallbackInfoGetPriority(callbackInfo); |
- objectInfo.changeObservers[priority] = observer; |
-} |
- |
-function ObjectInfoRemoveObserver(objectInfo, callback) { |
- if (!objectInfo.changeObservers) |
- return; |
- |
- if (ChangeObserversIsOptimized(objectInfo.changeObservers)) { |
- if (callback === ObserverGetCallback(objectInfo.changeObservers)) |
- objectInfo.changeObservers = null; |
- return; |
- } |
- |
- var callbackInfo = CallbackInfoGet(callback); |
- var priority = CallbackInfoGetPriority(callbackInfo); |
- objectInfo.changeObservers[priority] = null; |
-} |
- |
-function ObjectInfoHasActiveObservers(objectInfo) { |
- if (IS_UNDEFINED(objectInfo) || !objectInfo.changeObservers) |
- return false; |
- |
- if (ChangeObserversIsOptimized(objectInfo.changeObservers)) |
- return ObserverIsActive(objectInfo.changeObservers, objectInfo); |
- |
- for (var priority in objectInfo.changeObservers) { |
- var observer = objectInfo.changeObservers[priority]; |
- if (!IS_NULL(observer) && ObserverIsActive(observer, objectInfo)) |
- return true; |
- } |
- |
- return false; |
-} |
- |
- |
-function ObjectInfoAddPerformingType(objectInfo, type) { |
- objectInfo.performing = objectInfo.performing || TypeMapCreate(); |
- TypeMapAddType(objectInfo.performing, type); |
- objectInfo.performingCount++; |
-} |
- |
- |
-function ObjectInfoRemovePerformingType(objectInfo, type) { |
- objectInfo.performingCount--; |
- TypeMapRemoveType(objectInfo.performing, type); |
-} |
- |
- |
-function ObjectInfoGetPerformingTypes(objectInfo) { |
- return objectInfo.performingCount > 0 ? objectInfo.performing : null; |
-} |
- |
- |
-function ConvertAcceptListToTypeMap(arg) { |
- // We use undefined as a sentinel for the default accept list. |
- if (IS_UNDEFINED(arg)) |
- return arg; |
- |
- if (!IS_SPEC_OBJECT(arg)) throw MakeTypeError(kObserveInvalidAccept); |
- |
- var len = TO_INTEGER(arg.length); |
- if (len < 0) len = 0; |
- |
- return TypeMapCreateFromList(arg, len); |
-} |
- |
- |
-// CallbackInfo's optimized state is just a number which represents its global |
-// priority. When a change record must be enqueued for the callback, it |
-// normalizes. When delivery clears any pending change records, it re-optimizes. |
-function CallbackInfoGet(callback) { |
- return %WeakCollectionGet(GetObservationStateJS().callbackInfoMap, callback, |
- $getHash(callback)); |
-} |
- |
- |
-function CallbackInfoSet(callback, callbackInfo) { |
- %WeakCollectionSet(GetObservationStateJS().callbackInfoMap, |
- callback, callbackInfo, $getHash(callback)); |
-} |
- |
- |
-function CallbackInfoGetOrCreate(callback) { |
- var callbackInfo = CallbackInfoGet(callback); |
- if (!IS_UNDEFINED(callbackInfo)) |
- return callbackInfo; |
- |
- var priority = GetNextCallbackPriority(); |
- CallbackInfoSet(callback, priority); |
- return priority; |
-} |
- |
- |
-function CallbackInfoGetPriority(callbackInfo) { |
- if (IS_NUMBER(callbackInfo)) |
- return callbackInfo; |
- else |
- return callbackInfo.priority; |
-} |
- |
- |
-function CallbackInfoNormalize(callback) { |
- var callbackInfo = CallbackInfoGet(callback); |
- if (IS_NUMBER(callbackInfo)) { |
- var priority = callbackInfo; |
- callbackInfo = new InternalArray; |
- callbackInfo.priority = priority; |
- CallbackInfoSet(callback, callbackInfo); |
- } |
- return callbackInfo; |
-} |
- |
- |
-function ObjectObserve(object, callback, acceptList) { |
- if (!IS_SPEC_OBJECT(object)) |
- throw MakeTypeError(kObserveNonObject, "observe", "observe"); |
- if (%IsJSGlobalProxy(object)) |
- throw MakeTypeError(kObserveGlobalProxy, "observe"); |
- if (%IsAccessCheckNeeded(object)) |
- throw MakeTypeError(kObserveAccessChecked, "observe"); |
- if (!IS_CALLABLE(callback)) |
- throw MakeTypeError(kObserveNonFunction, "observe"); |
- if (ObjectIsFrozen(callback)) |
- throw MakeTypeError(kObserveCallbackFrozen); |
- |
- var objectObserveFn = %GetObjectContextObjectObserve(object); |
- return objectObserveFn(object, callback, acceptList); |
-} |
- |
- |
-function NativeObjectObserve(object, callback, acceptList) { |
- var objectInfo = ObjectInfoGetOrCreate(object); |
- var typeList = ConvertAcceptListToTypeMap(acceptList); |
- ObjectInfoAddObserver(objectInfo, callback, typeList); |
- return object; |
-} |
- |
- |
-function ObjectUnobserve(object, callback) { |
- if (!IS_SPEC_OBJECT(object)) |
- throw MakeTypeError(kObserveNonObject, "unobserve", "unobserve"); |
- if (%IsJSGlobalProxy(object)) |
- throw MakeTypeError(kObserveGlobalProxy, "unobserve"); |
- if (!IS_CALLABLE(callback)) |
- throw MakeTypeError(kObserveNonFunction, "unobserve"); |
- |
- var objectInfo = ObjectInfoGet(object); |
- if (IS_UNDEFINED(objectInfo)) |
- return object; |
- |
- ObjectInfoRemoveObserver(objectInfo, callback); |
- return object; |
-} |
- |
- |
-function ArrayObserve(object, callback) { |
- return ObjectObserve(object, callback, ['add', |
- 'update', |
- 'delete', |
- 'splice']); |
-} |
- |
- |
-function ArrayUnobserve(object, callback) { |
- return ObjectUnobserve(object, callback); |
-} |
- |
- |
-function ObserverEnqueueIfActive(observer, objectInfo, changeRecord) { |
- if (!ObserverIsActive(observer, objectInfo) || |
- !TypeMapHasType(ObserverGetAcceptTypes(observer), changeRecord.type)) { |
- return; |
- } |
- |
- var callback = ObserverGetCallback(observer); |
- if (!%ObserverObjectAndRecordHaveSameOrigin(callback, changeRecord.object, |
- changeRecord)) { |
- return; |
- } |
- |
- var callbackInfo = CallbackInfoNormalize(callback); |
- if (IS_NULL(GetPendingObservers())) { |
- SetPendingObservers(nullProtoObject()); |
- if (DEBUG_IS_ACTIVE) { |
- var id = ++GetObservationStateJS().lastMicrotaskId; |
- var name = "Object.observe"; |
- %EnqueueMicrotask(function() { |
- %DebugAsyncTaskEvent({ type: "willHandle", id: id, name: name }); |
- ObserveMicrotaskRunner(); |
- %DebugAsyncTaskEvent({ type: "didHandle", id: id, name: name }); |
- }); |
- %DebugAsyncTaskEvent({ type: "enqueue", id: id, name: name }); |
- } else { |
- %EnqueueMicrotask(ObserveMicrotaskRunner); |
- } |
- } |
- GetPendingObservers()[callbackInfo.priority] = callback; |
- callbackInfo.push(changeRecord); |
-} |
- |
- |
-function ObjectInfoEnqueueExternalChangeRecord(objectInfo, changeRecord, type) { |
- if (!ObjectInfoHasActiveObservers(objectInfo)) |
- return; |
- |
- var hasType = !IS_UNDEFINED(type); |
- var newRecord = hasType ? |
- { object: objectInfo.object, type: type } : |
- { object: objectInfo.object }; |
- |
- for (var prop in changeRecord) { |
- if (prop === 'object' || (hasType && prop === 'type')) continue; |
- %DefineDataPropertyUnchecked( |
- newRecord, prop, changeRecord[prop], READ_ONLY + DONT_DELETE); |
- } |
- ObjectFreeze(newRecord); |
- |
- ObjectInfoEnqueueInternalChangeRecord(objectInfo, newRecord); |
-} |
- |
- |
-function ObjectInfoEnqueueInternalChangeRecord(objectInfo, changeRecord) { |
- // TODO(rossberg): adjust once there is a story for symbols vs proxies. |
- if (IS_SYMBOL(changeRecord.name)) return; |
- |
- if (ChangeObserversIsOptimized(objectInfo.changeObservers)) { |
- var observer = objectInfo.changeObservers; |
- ObserverEnqueueIfActive(observer, objectInfo, changeRecord); |
- return; |
- } |
- |
- for (var priority in objectInfo.changeObservers) { |
- var observer = objectInfo.changeObservers[priority]; |
- if (IS_NULL(observer)) |
- continue; |
- ObserverEnqueueIfActive(observer, objectInfo, changeRecord); |
- } |
-} |
- |
- |
-function BeginPerformSplice(array) { |
- var objectInfo = ObjectInfoGet(array); |
- if (!IS_UNDEFINED(objectInfo)) |
- ObjectInfoAddPerformingType(objectInfo, 'splice'); |
-} |
- |
- |
-function EndPerformSplice(array) { |
- var objectInfo = ObjectInfoGet(array); |
- if (!IS_UNDEFINED(objectInfo)) |
- ObjectInfoRemovePerformingType(objectInfo, 'splice'); |
-} |
- |
- |
-function EnqueueSpliceRecord(array, index, removed, addedCount) { |
- var objectInfo = ObjectInfoGet(array); |
- if (!ObjectInfoHasActiveObservers(objectInfo)) |
- return; |
- |
- var changeRecord = { |
- type: 'splice', |
- object: array, |
- index: index, |
- removed: removed, |
- addedCount: addedCount |
- }; |
- |
- ObjectFreeze(changeRecord); |
- ObjectFreeze(changeRecord.removed); |
- ObjectInfoEnqueueInternalChangeRecord(objectInfo, changeRecord); |
-} |
- |
- |
-function NotifyChange(type, object, name, oldValue) { |
- var objectInfo = ObjectInfoGet(object); |
- if (!ObjectInfoHasActiveObservers(objectInfo)) |
- return; |
- |
- var changeRecord; |
- if (arguments.length == 2) { |
- changeRecord = { type: type, object: object }; |
- } else if (arguments.length == 3) { |
- changeRecord = { type: type, object: object, name: name }; |
- } else { |
- changeRecord = { |
- type: type, |
- object: object, |
- name: name, |
- oldValue: oldValue |
- }; |
- } |
- |
- ObjectFreeze(changeRecord); |
- ObjectInfoEnqueueInternalChangeRecord(objectInfo, changeRecord); |
-} |
- |
- |
-function ObjectNotifierNotify(changeRecord) { |
- if (!IS_SPEC_OBJECT(this)) |
- throw MakeTypeError(kCalledOnNonObject, "notify"); |
- |
- var objectInfo = ObjectInfoGetFromNotifier(this); |
- if (IS_UNDEFINED(objectInfo)) |
- throw MakeTypeError(kObserveNotifyNonNotifier); |
- if (!IS_STRING(changeRecord.type)) |
- throw MakeTypeError(kObserveTypeNonString); |
- |
- ObjectInfoEnqueueExternalChangeRecord(objectInfo, changeRecord); |
-} |
- |
- |
-function ObjectNotifierPerformChange(changeType, changeFn) { |
- if (!IS_SPEC_OBJECT(this)) |
- throw MakeTypeError(kCalledOnNonObject, "performChange"); |
- |
- var objectInfo = ObjectInfoGetFromNotifier(this); |
- if (IS_UNDEFINED(objectInfo)) |
- throw MakeTypeError(kObserveNotifyNonNotifier); |
- if (!IS_STRING(changeType)) |
- throw MakeTypeError(kObservePerformNonString); |
- if (!IS_CALLABLE(changeFn)) |
- throw MakeTypeError(kObservePerformNonFunction); |
- |
- var performChangeFn = %GetObjectContextNotifierPerformChange(objectInfo); |
- performChangeFn(objectInfo, changeType, changeFn); |
-} |
- |
- |
-function NativeObjectNotifierPerformChange(objectInfo, changeType, changeFn) { |
- ObjectInfoAddPerformingType(objectInfo, changeType); |
- |
- var changeRecord; |
- try { |
- changeRecord = changeFn(); |
- } finally { |
- ObjectInfoRemovePerformingType(objectInfo, changeType); |
- } |
- |
- if (IS_SPEC_OBJECT(changeRecord)) |
- ObjectInfoEnqueueExternalChangeRecord(objectInfo, changeRecord, changeType); |
-} |
- |
- |
-function ObjectGetNotifier(object) { |
- if (!IS_SPEC_OBJECT(object)) |
- throw MakeTypeError(kObserveNonObject, "getNotifier", "getNotifier"); |
- if (%IsJSGlobalProxy(object)) |
- throw MakeTypeError(kObserveGlobalProxy, "getNotifier"); |
- if (%IsAccessCheckNeeded(object)) |
- throw MakeTypeError(kObserveAccessChecked, "getNotifier"); |
- |
- if (ObjectIsFrozen(object)) return null; |
- |
- if (!%ObjectWasCreatedInCurrentOrigin(object)) return null; |
- |
- var getNotifierFn = %GetObjectContextObjectGetNotifier(object); |
- return getNotifierFn(object); |
-} |
- |
- |
-function NativeObjectGetNotifier(object) { |
- var objectInfo = ObjectInfoGetOrCreate(object); |
- return ObjectInfoGetNotifier(objectInfo); |
-} |
- |
- |
-function CallbackDeliverPending(callback) { |
- var callbackInfo = CallbackInfoGet(callback); |
- if (IS_UNDEFINED(callbackInfo) || IS_NUMBER(callbackInfo)) |
- return false; |
- |
- // Clear the pending change records from callback and return it to its |
- // "optimized" state. |
- var priority = callbackInfo.priority; |
- CallbackInfoSet(callback, priority); |
- |
- var pendingObservers = GetPendingObservers(); |
- if (!IS_NULL(pendingObservers)) |
- delete pendingObservers[priority]; |
- |
- // TODO: combine the following runtime calls for perf optimization. |
- var delivered = []; |
- %MoveArrayContents(callbackInfo, delivered); |
- %DeliverObservationChangeRecords(callback, delivered); |
- |
- return true; |
-} |
- |
- |
-function ObjectDeliverChangeRecords(callback) { |
- if (!IS_CALLABLE(callback)) |
- throw MakeTypeError(kObserveNonFunction, "deliverChangeRecords"); |
- |
- while (CallbackDeliverPending(callback)) {} |
-} |
- |
- |
-function ObserveMicrotaskRunner() { |
- var pendingObservers = GetPendingObservers(); |
- if (!IS_NULL(pendingObservers)) { |
- SetPendingObservers(null); |
- for (var i in pendingObservers) { |
- CallbackDeliverPending(pendingObservers[i]); |
- } |
- } |
-} |
- |
-// ------------------------------------------------------------------- |
- |
-utils.InstallFunctions(notifierPrototype, DONT_ENUM, [ |
- "notify", ObjectNotifierNotify, |
- "performChange", ObjectNotifierPerformChange |
-]); |
- |
-$observeObjectMethods = [ |
- "deliverChangeRecords", ObjectDeliverChangeRecords, |
- "getNotifier", ObjectGetNotifier, |
- "observe", ObjectObserve, |
- "unobserve", ObjectUnobserve |
-]; |
-$observeArrayMethods = [ |
- "observe", ArrayObserve, |
- "unobserve", ArrayUnobserve |
-]; |
- |
-// TODO(adamk): Figure out why this prototype removal has to |
-// happen as part of initial snapshotting. |
-var removePrototypeFn = function(f, i) { |
- if (i % 2 === 1) %FunctionRemovePrototype(f); |
-}; |
-$observeObjectMethods.forEach(removePrototypeFn); |
-$observeArrayMethods.forEach(removePrototypeFn); |
- |
-$observeEnqueueSpliceRecord = EnqueueSpliceRecord; |
-$observeBeginPerformSplice = BeginPerformSplice; |
-$observeEndPerformSplice = EndPerformSplice; |
- |
-%InstallToContext([ |
- "native_object_get_notifier", NativeObjectGetNotifier, |
- "native_object_notifier_perform_change", NativeObjectNotifierPerformChange, |
- "native_object_observe", NativeObjectObserve, |
- "observers_begin_perform_splice", BeginPerformSplice, |
- "observers_end_perform_splice", EndPerformSplice, |
- "observers_enqueue_splice", EnqueueSpliceRecord, |
- "observers_notify_change", NotifyChange, |
-]); |
- |
-}) |