anchor.diff:  
   view_cb({meta, Meta}, Acc) ->
       % Map function starting
  -    case rexi:sync_reply({meta, Meta}) of
  +    case rexi:stream2({meta, Meta}) of
           ok ->
               {ok, Acc};
           stop ->
  
positive.code:             exit(timeout)
          end;
      true ->
          case rexi:stream(#view_row{key=Key, value=Value}) of
          ok ->
              {ok, Acc};
          timeout ->
  
negative.code:         value = couch_util:get_value(value, Row),
          doc = couch_util:get_value(doc, Row)
      },
      case rexi:stream2(ViewRow) of
          ok ->
              {ok, Acc};
          timeout ->
  