anchor.diff:      {ok, worker_host:plugin_state()} | {error, Reason :: term()}.
   init([]) ->
       schedule_subscription_renew(),
  -    schedule_connection_start(),
       {ok, #{}}.
   
   %%--------------------------------------------------------------------
  
positive.code:         {resume_at, ResumeAt},
          {missing, Missing}
      ]),
      subscription_wss:push(Message).
  
  %%--------------------------------------------------------------------
  
negative.code: 
      {ok, _} = timer:send_after(Delay, whereis(?MODULE),
          {timer, start_provider_connection}),
      ok.
  
  
  %%--------------------------------------------------------------------
  %% @doc @private
  %% Ensures if websocket is running & registered.
  %% @end
  %%--------------------------------------------------------------------
  -spec ensure_connection_running() -> ok | {error, Reason :: term()}.
  ensure_connection_running() ->
      case whereis(subscription_wss) of
          undefined ->
              worker_proxy:call(subscriptions_worker, start_provider_connection);
          _ -> ok
      end.