<commit_before>﻿using System;
using System.Threading.Tasks;
using Angora;

namespace Consumer
{
    class Program
    {
        static void Main(string[] args)
        {
            MainAsync().GetAwaiter().GetResult();
        }

        static async Task MainAsync()
        {
            var factory = new ConnectionFactory
            {
                HostName = "rabbit"
            };

            var connection = await factory.CreateConnection("Consumer");

            var channel = await connection.CreateChannel();

            await channel.Queue.Declare("test", false, true, false, false, null);

            await channel.Basic.Qos(0, 1, false);

            var consumer = new MesssageConsumer(channel.Basic);
            var consumerTag = await channel.Basic.Consume("test", "Consumer", false, false, null, consumer.HandleIncomingMessage);

            Console.WriteLine("Consumer started. Press any key to quit.");
            Console.ReadKey();

            await channel.Basic.Cancel(consumerTag);

            await channel.Close();

            await connection.Close();
        }
    }

    class MesssageConsumer
    {
        Basic basic;

        public MesssageConsumer(Basic basic)
        {
            this.basic = basic;
        }

        public async Task HandleIncomingMessage(Basic.DeliverState messageState)
        {
            await basic.Ack(messageState.DeliveryTag, false);
        }
    }
}<commit_msg>Bump prefetch count to 1000<commit_after>﻿using System;
using System.Threading.Tasks;
using Angora;

namespace Consumer
{
    class Program
    {
        static void Main(string[] args)
        {
            MainAsync().GetAwaiter().GetResult();
        }

        static async Task MainAsync()
        {
            var factory = new ConnectionFactory
            {
                HostName = "rabbit"
            };

            var connection = await factory.CreateConnection("Consumer");

            var channel = await connection.CreateChannel();

            await channel.Queue.Declare("test", false, true, false, false, null);

            await channel.Basic.Qos(0, 1000, false);

            var consumer = new MesssageConsumer(channel.Basic);
            var consumerTag = await channel.Basic.Consume("test", "Consumer", false, false, null, consumer.HandleIncomingMessage);

            Console.WriteLine("Consumer started. Press any key to quit.");
            Console.ReadKey();

            await channel.Basic.Cancel(consumerTag);

            await channel.Close();

            await connection.Close();
        }
    }

    class MesssageConsumer
    {
        Basic basic;

        public MesssageConsumer(Basic basic)
        {
            this.basic = basic;
        }

        public async Task HandleIncomingMessage(Basic.DeliverState messageState)
        {
            await basic.Ack(messageState.DeliveryTag, false);
        }
    }
}
{'fraction_non_alphanumeric': 0.09425524595803234, 'fraction_numerical': 0.003783969728242174, 'mean_word_length': 1.905094905094905, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1524839', 'n_tokens_mistral': 748, 'n_tokens_neox': 719, 'n_words': 180}