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:             {deleted, Del} |
              if IncludeDocs -> [doc_member(Db, DocInfo, Opts)]; true -> [] end
          ]},
          Go = rexi:sync_reply(ChangesRow),
          {Go, Acc#cacc{seq = Seq, pending = Pending-1}}
      end.
  
  
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 ->
  