1515 */
1616
1717
18- const ReplicatedEntity = require ( "@lightbend/akkaserverless-javascript-sdk" ) . replicatedentity . ReplicatedEntity ;
19- const ReplicatedData = require ( "@lightbend/akkaserverless-javascript-sdk" ) . replicatedentity . ReplicatedData ;
18+ const replicatedentity = require ( "@lightbend/akkaserverless-javascript-sdk" ) . replicatedentity ;
2019
21- const entity = new ReplicatedEntity (
20+ const entity = new replicatedentity . ReplicatedEntity (
2221 "replicated_entity_example.proto" ,
2322 "com.example.replicatedentity.ReplicatedEntityExample" ,
2423 "replicated-entity-example"
@@ -33,7 +32,7 @@ entity.commandHandlers = {
3332
3433function updateReplicatedCounter ( update , ctx ) {
3534 if ( ctx . state === null ) {
36- ctx . state = new ReplicatedData . ReplicatedCounter ( ) ;
35+ ctx . state = new replicatedentity . ReplicatedCounter ( ) ;
3736 }
3837
3938 if ( update . value !== 0 ) {
@@ -46,7 +45,7 @@ function updateReplicatedCounter(update, ctx) {
4645
4746function getReplicatedCounter ( get , ctx ) {
4847 if ( ctx . state === null ) {
49- ctx . state = new ReplicatedData . ReplicatedCounter ( ) ;
48+ ctx . state = new replicatedentity . ReplicatedCounter ( ) ;
5049 }
5150
5251 return {
@@ -56,7 +55,7 @@ function getReplicatedCounter(get, ctx) {
5655
5756function mutateReplicatedSet ( update , ctx ) {
5857 if ( ctx . state === null ) {
59- ctx . state = new ReplicatedData . ReplicatedSet ( ) ;
58+ ctx . state = new replicatedentity . ReplicatedSet ( ) ;
6059 }
6160
6261 if ( update . clear ) {
@@ -76,7 +75,7 @@ function mutateReplicatedSet(update, ctx) {
7675
7776function getReplicatedSet ( get , ctx ) {
7877 if ( ctx . state === null ) {
79- ctx . state = new ReplicatedData . ReplicatedSet ( ) ;
78+ ctx . state = new replicatedentity . ReplicatedSet ( ) ;
8079 }
8180
8281 return {
0 commit comments