anchor.diff:                 stderr_to_stdout,
                  {env, JobEnvs}],
       Port = open_port({spawn, Command}, Options),
  -    SendPid = spawn_link(fun() -> worker_send(Port) end),
  +    SendPid = spawn_link(fun() -> worker_send(T, Port) end),
       {noreply, State#state{port = Port, worker_send = SendPid}, ?PID_TIMEOUT}.
   
   
  
positive.code:             handle_info({none, {data, <<>>}}, S#state{error_output = true})
      end.
  
  -spec worker_send(port()) -> no_return().
  worker_send(Port) ->
      receive
          {{MsgName, Payload}, Delay} ->
              timer:sleep(Delay),
  
negative.code: -define(ERROR_TIMEOUT, 10 * 1000).
  -define(MESSAGE_TIMEOUT, 30 * 1000).
  -define(MAX_ERROR_BUFFER_SIZE, 100 * 1024).
  -define(LOG_PROTOCOL, false).
  
  -spec start_link_remote(host(), pid(), task()) -> no_return().
  start_link_remote(Host, NodeMon, Task) ->
  