I’m developing a real-time collaborative application that relies on real-time database functionality. I’m evaluating whether Rama would be a better fit than Firestore for this use case. Specifically:
public class CollaborativeExampleModule implements RamaModule {
@Override
public void define(Setup setup, Topologies topologies) {setup.declareDepot("*incrementsDepot", Depot.hashBy(Ops.IDENTITY));StreamTopology s = topologies.stream("entity");s.pstate("$$entityCounts", PState.mapSchema(String.class, Integer.class));s.source("*incrementsDepot").out("*entityid").compoundAgg("$$entityCounts", CompoundAgg.map("*entityId", Agg.count()));}}
When that call returns, the user's increment has been applied to that entity (along with any others that were happening concurrently).incrementsDepot.append("someEntityId");
--
You received this message because you are subscribed to the Google Groups "rama-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rama-user+...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/rama-user/0dad314b-ce67-4256-a0b3-f886aa2b3895n%40googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/rama-user/6a53ffb0-2027-492d-94c5-c4f3f4fc029en%40googlegroups.com.