anchor.diff:      AccValue = lists:foldl(Function, Type:new(), Operations),
   
       %% Update with result.
  -    BindFun(AccId, AccValue, Variables),
  -
  -    fold_harness(Variables, Id, Function, AccId, BindFun, ReadFun, Value, AccValue).
  +    {ok, _} = BindFun(AccId, AccValue, Variables),
  +
  +    fold_harness(Variables, Id, Function, AccId, BindFun, ReadFun,
  +                 Value, AccValue).
   
   %% @doc Send responses to waiting threads, via messages.
   %%
  
positive.code: %% @doc Given a group of processes which are blocking on reads, notify
  %%      them of bound values or met thresholds.
  %%
  -spec reply_to_all(list(pid() | pending_threshold()), list(pending_threshold()),
                     term()) -> {ok, list(pending_threshold())}.
  reply_to_all([{threshold, read, From, Type, Threshold}=H|T],
               StillWaiting0,
               {ok, Type, Value, Next}=Result) ->
      StillWaiting = case lasp_lattice:threshold_met(Type, Value, Threshold) of
          true ->
              case From of
                  {server, undefined, {Address, Ref}} ->
  
negative.code:                                                       Threshold}])
                      end,
                      true = ets:insert(Store,
                                        {Id,
                                         V#dv{lazy_threads=LazyThreads}}),
                      BlockingFun()
              end
      end.
  