gistfile1.txt

Counters = fabric_dict:init(Workers0, nil),
    RexiMon = fabric_util:create_monitors(Workers0),
    try
        case fabric_util:stream_start(Workers0, #shard.ref) of
            {ok, Workers} ->
                try
                    go(DbName, DDoc, IndexName, QueryArgs, Counters, Counters,HttpResp)
                after
                
Counters = fabric_dict:init(Workers0, nil),
    RexiMon = fabric_util:create_monitors(Workers0),
    try
        case fabric_util:stream_start(Workers0, #shard.ref) of
            {ok, Workers} ->
                try
                    go(DbName, DDoc, IndexName, QueryArgs, Workers, Counters,HttpResp)
                after