anchor.diff:  send(Key, Value, Acc) ->
       case put(fabric_sent_first_row, true) of
       undefined ->
  -        case rexi:sync_reply(#view_row{key=Key, value=Value}) of
  +        case rexi:stream2(#view_row{key=Key, value=Value}) of
           ok ->
               {ok, Acc};
           stop ->
  
positive.code: 
  view_cb({meta, Meta}, Acc) ->
      % Map function starting
      case rexi:sync_reply({meta, Meta}) of
          ok ->
              {ok, Acc};
          stop ->
  
negative.code:             {deleted, Del} |
              if IncludeDocs -> [doc_member(Db, DocInfo, Opts)]; true -> [] end
          ]},
          Go = rexi:stream2(ChangesRow),
          {Go, Acc#cacc{seq = Seq, pending = Pending-1}}
      end.
  
  