anchor.diff:  -export([test/0,
            buffer/3,
            producer/3,
  -         consumer/3]).
  +         consumer/4]).
   
   -ifdef(TEST).
   
  
positive.code:             drop_list(Next, Size - 1)
      end.
  
  consumer(S2, Size, F) ->
      case Size of
          0 ->
              ok;
          _ ->
              case derflow:consume(S2) of
                  {ok, nil, _} ->
                      ok;
                  {ok, _Value, Next} ->
                      consumer(Next, Size - 1, F)
              end
      end.
  
negative.code:     lager:info("Remote code loading complete."),
  
      lager:info("Remotely executing the test."),
      Result = rpc:call(Node, ?MODULE, test, []),
      ?assertEqual([0,2,4], Result),
      pass.
  
  -endif.
  
  test() ->
      {ok, S1} = derflow:declare(),
      spawn(derflow_bounded_buffer_test, producer, [0, 3, S1]),
      {ok, S2} = derflow:declare(),
      spawn(derflow_bounded_buffer_test, buffer, [S1, 2, S2]),
      {ok, S3} = derflow:declare(),
      consumer(S2, 5, fun(X) -> X*2 end, S3),
      derflow:get_stream(S3).
  
  producer(Value, N, Output) ->
      if
  