(function() {

    const st = new ShardingTest({shards: 2});

    assert.commandWorked(st.s.adminCommand({enableSharding: 'test'}));
    st.ensurePrimaryShard("test", st.shard0.shardName);

    assert.commandWorked(st.s.adminCommand({shardCollection: 'test.user', key: {_id: 1}}));

    const mongosDB = st.s.getDB('test');
    const coll = mongosDB.user;
    coll.insert({_id: 1});
    coll.insert({_id: -1});

    var res = assert.commandWorked(mongosDB.runCommand({
        aggregate: coll.getName(),
        pipeline: [],
        exchange: {policy: 'broadcast', consumers: NumberInt(5), bufferSize: NumberInt(1024)},
        cursor: {batchSize: 0}
    }));

    st.stop();
})();