load all

hazelcast · Apr 25, 2016 · 8b00a3e · 8b00a3e
1 parent ad0e755
commit 8b00a3e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/src/codec/MapLoadGivenKeysCodec.ts b/src/codec/MapLoadGivenKeysCodec.ts
@@ -1,12 +1,12 @@
 /* tslint:disable */
 import ClientMessage = require('../ClientMessage');
-import ImmutableLazyDataList = require('./ImmutableLazyDataList');
 import {BitsUtil} from '../BitsUtil';
 import Address = require('../Address');
 import {AddressCodec} from './AddressCodec';
 import {MemberCodec} from './MemberCodec';
 import {Data} from '../serialization/Data';
 import {EntryViewCodec} from './EntryViewCodec';
+import DistributedObjectInfoCodec = require('./DistributedObjectInfoCodec');
 import {MapMessageType} from './MapMessageType';
 
 var REQUEST_TYPE = MapMessageType.MAP_LOADGIVENKEYS;
@@ -23,7 +23,7 @@ export class MapLoadGivenKeysCodec {
         dataSize += BitsUtil.calculateSizeString(name);
         dataSize += BitsUtil.INT_SIZE_IN_BYTES;
 
-        keys.foreach((keysItem:any) => {
+        keys.forEach((keysItem:any) => {
             dataSize += BitsUtil.calculateSizeData(keysItem);
         });
         dataSize += BitsUtil.BOOLEAN_SIZE_IN_BYTES;
@@ -38,7 +38,7 @@ export class MapLoadGivenKeysCodec {
         clientMessage.appendString(name);
         clientMessage.appendInt32(keys.length);
 
-        keys.foreach((keysItem:any) => {
+        keys.forEach((keysItem:any) => {
             clientMessage.appendData(keysItem);
         });
 

diff --git a/src/proxy/Map.ts b/src/proxy/Map.ts
@@ -32,6 +32,7 @@ import {MapReplaceCodec} from '../codec/MapReplaceCodec';
 import {MapReplaceIfSameCodec} from '../codec/MapReplaceIfSameCodec';
 import {MapSetCodec} from '../codec/MapSetCodec';
 import {MapValuesCodec} from '../codec/MapValuesCodec';
+import {MapLoadGivenKeysCodec} from '../codec/MapLoadGivenKeysCodec';
 export class Map<K, V> extends BaseProxy implements IMap<K, V> {
     containsKey(key: K): Q.Promise<boolean> {
         var keyData = this.toData(key);
@@ -174,7 +175,9 @@ export class Map<K, V> extends BaseProxy implements IMap<K, V> {
         if (keys == null) {
             return this.encodeInvokeOnRandomTarget<void>(MapLoadAllCodec, replaceExistingValues);
         } else {
-            //TODO MapLoadGivenKeysCodec
+            var toData = this.toData.bind(this);
+            var keysData: Data[] = keys.map<Data>(toData);
+            return this.encodeInvokeOnRandomTarget<void>(MapLoadGivenKeysCodec, keysData, replaceExistingValues);
         }
     }