anchor.diff:  
       {ok, _} = timer:send_after(Delay, whereis(?MODULE),
           {timer, start_provider_connection}),
  -    ok.+    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.
positive.code:     {ok, worker_host:plugin_state()} | {error, Reason :: term()}.
  init([]) ->
      schedule_subscription_renew(),
      schedule_connection_start(),
      {ok, #{}}.
  
  %%--------------------------------------------------------------------
  
negative.code:         {resume_at, ResumeAt},
          {missing, Missing}
      ]),
  
      ensure_connection_running(),
      subscription_wss:push(Message).
  
  %%--------------------------------------------------------------------
  