anchor.diff:          <<"kind">> := Kind,
           <<"x_env">> := XEnv} = Cmd,
       Self = self(),
  -    spawn(fun() -> get_finals(Self, StreamId, BenchIds, binary_to_list(MetricName), Kind, XEnv) end),
  +    spawn(fun() -> get_finals(Self, StreamId, BenchIds, MetricName, Kind, XEnv) end),
       {ok, State};
   
   dispatch_request(#{<<"cmd">> := <<"start_streaming_metric">>} = Cmd, State) ->
  
positive.code:         lists:any(fun(#{metrics:= Metrics}) ->
              lists:any(fun(#{name:= Name}) when Name == Metric -> true; (_) -> false end, Metrics)
                  end, Graphs) end, Groups);
  has_metric(Metric, _, #{results:= Res}) ->
      mzb_bc:maps_get(Metric, Res, false);
  has_metric(_, _, _) ->
      false.
  
  get_bench_env(EnvName, #{env:= Env}) ->
      mzb_bc:maps_get(EnvName, Env, []).
  
negative.code: get_last_value(BenchId, MetricName) ->
      Status = mzb_api_server:status(BenchId),
      Time = mzb_bc:maps_get(finish_time, Status, 0),
      {Time, find_result_metric(MetricName, mzb_api_endpoints:format_results(Status), 0)}.
  
  %% Normalization
  
  