anchor.diff:  -define(kGetTokenId,3).
   -define(kSubmitPayload,4).
   -define(kError,5).
  +
  +%% Worker comm timeout
  +-define(WORKER_REPLY_TIMEOUT, 3000).
   
   
   %%%===================================================================
  
positive.code: p_read_reply(Port) ->
      receive
          {Port, {data, <<Size:32/integer-signed-little,Msg/binary>>}} ->
              {Size, Msg}
      end.
  
negative.code:     %% Send a kEcho request to the worker
      lager:info("Sending kEcho request to worker process."),
      p_write_request(WorkerPort, ?kEcho, <<"Ping">>),
      {ok, {Size, Msg}} = p_read_reply(WorkerPort),
      lager:info("Received kEcho reply from worker: size: ~p, msg: ~p", [Size, Msg]),
      {ok, #{worker => WorkerPort}}.
  
  