Skip to content
This repository was archived by the owner on Sep 28, 2021. It is now read-only.

Commit e29ff45

Browse files
committed
Fix interest types.
1 parent 1b0b1e2 commit e29ff45

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

include/lasp.hrl

+1
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
%% Interests.
66
-define(INTERESTS_TYPE, awmap).
77
-define(INTERESTS_ID, {<<"_interests">>, ?INTERESTS_TYPE}).
8+
-define(OBJECT_INTERESTS_TYPE, awset).
89

910
%% Simulations.
1011
-define(SIMPLE_BOOLEAN, {<<"boolean">>, ?BOOLEAN_TYPE}).

src/lasp_state_based_synchronization_backend.erl

+2-1
Original file line numberDiff line numberDiff line change
@@ -434,7 +434,8 @@ init_state_sync(Peer, ObjectFilterFun, Blocking, Store) ->
434434
ObjectTopics = case orddict:find(topics, Metadata) of
435435
{ok, T} ->
436436
%% TODO: Fix me
437-
{ok, Topics} = state_awset:query(T),
437+
Type = lasp_type:get_type(?OBJECT_INTERESTS_TYPE),
438+
{ok, Topics} = Type:query(T),
438439
Topics;
439440
_ ->
440441
sets:new()

0 commit comments

Comments
 (0)