anchor.diff:      {ok, worker_host:plugin_state()} | {error, Reason :: term()}.
   init([]) ->
       schedule_subscription_renew(),
  -    schedule_connection_start(),
       {ok, #{}}.
   
   %%--------------------------------------------------------------------
  
positive.code: 
      {ok, _} = timer:send_after(Delay, whereis(?MODULE),
          {timer, start_provider_connection}),
      ok.
negative.code:     ok;
  
  handle({'EXIT', _Pid, _Reason} = Req) ->
      %% Handle possible websocket crashes
      case subscription_wss:healthcheck() of
          {error, _} ->
              ?error("Subscriptions connection crashed: ~p", [_Reason]),
  