anchor.diff:      unlink(Pid),
       [{channel,ChannelId},{port,Port},{drain,Pid} | Config].
   
  +end_per_testcase(shrink, Config) ->
  +    end_tcp_server(Config);
   end_per_testcase(_, Config) ->
       Drain = ?config(drain,Config),
       erlang:monitor(process, Drain),
  
positive.code:     {match, _} = re:run(Logs, "mymsg5"),
      {match, _} = re:run(Logs, "mymsg6"),
      {match, _} = re:run(Logs, "mymsg7").
  
  %%%%%%%%%%%%%
  %%% UTILS %%%
  
negative.code: end_per_group(_, _Config) ->
      ok.
  
  init_per_testcase(shrink, Config) ->
      with_tcp_server([{channel, 1337} | Config]);
  init_per_testcase(_, Config) ->
      application:set_env(logplex, tcp_drain_buffer_size, 5),
      Port = start_server(Config),
  