anchor.diff:       GLocalLearner  :: comm:mypid(),
        %% reference counting on subscriptions inside RTMs
        Subs           :: [{comm:mypid(), non_neg_integer()}],
  -     OpenTxNum      :: non_neg_integer(),
  -     QueuedMessages :: msg_queue:msg_queue()}.
  +     OpenTxNum      :: non_neg_integer()}.
   
   %% initialize: return initial state.
   -spec init([]) -> state() | {'$gen_component', [{on_handler, on_init},...],
  
positive.code: state_inc_opentxnum(State) -> setelement(7, State, element(7, State) + 1).
  -spec state_dec_opentxnum(state()) -> state().
  state_dec_opentxnum(State) -> setelement(7, State, element(7, State) - 1).
  -spec state_get_qmsg(state()) -> msg_queue:msg_queue().
  state_get_qmsg(State)          -> element(8, State).
  -spec state_set_qmsg(state(), msg_queue:msg_queue()) -> state().
  state_set_qmsg(State, Val)     -> setelement(8, State, Val).
  
  -spec state_subscribe(state(), comm:mypid()) -> state().
  state_subscribe(State, Pid) ->
  
negative.code:     case lists:keymember(unknown, 2, NewRTMs) of %% filled all entries?
          false ->
              rtms_of_same_dht_node(NewRTMs),
              gen_component:change_handler(state_set_RTMs(State, NewRTMs), on);
          _ -> state_set_RTMs(State, NewRTMs)
      end;
  
  