MihaZupan

class RedisDatabase : ISimpleDatabase
{
    private readonly ConnectionMultiplexer _redis = ConnectionMultiplexer.Connect("localhost");

    public async Task<string> GetAsync(string dataSet, string key)
    {
        return await _redis.GetDatabase().HashGetAsync(dataSet, key);
    }

    public async Task SetAsync(string dataSet, string key, string value)

MihaZupan

readonly HttpToSocks5Proxy Socks5Proxy = new HttpToSocks5Proxy("proxyAddress", 1080);

TcpClient TcpOverSocks5ClientConnectionHandler(string address, int port)
{
    string connectMessage = string.Format(
        "CONNECT {0} HTTP/1.1\r\nHost: {0}\r\n\r\n",
        address + ":" + port);

    byte[] connectMessageBytes = Encoding.UTF8.GetBytes(connectMessage);

MihaZupan

public static class CharHelper
{
    [MethodImpl(MethodImplOptionPortable.AggressiveInlining)]
    public static bool IsRomanLetterPartial(char c)
    {
        // We don't support LCDM
        /* return IsRomanLetterLowerPartial(c) || IsRomanLetterUpperPartial(c); */

        int testValue = c - 73;
        if ((uint)testValue > 47)

MihaZupan

public long GetBucket(Update update)
{
    if (update.Message is Message message)
        return message.Chat.Id;

    if (update.ChosenInlineResult is ChosenInlineResult chosenInlineResult)
        return chosenInlineResult.From.Id;

    if (update.InlineQuery is InlineQuery inlineQuery)
        return inlineQuery.From.Id;

MihaZupan

// This file is licensed under the BSD-Clause 2 license. 
// See the license.txt file in the project root for more information.

using System;
using Markdig.Helpers;
using Markdig.Renderers.Html;
using Markdig.Syntax;

namespace Markdig.Parsers
{

MihaZupan

var updateReceiver = new QueuedUpdateReceiver(Bot);

updateReceiver.StartReceiving(new[] { UpdateType.Message }, errorHandler: HandleErrorAsync);

_ = Task.Run(async () => {
    while (true)
    {
        Console.WriteLine(
            DateTime.Now.Second.ToString().PadLeft(2, '0') +
            " Pending: " + updateReceiver.PendingUpdates +

MihaZupan

using System;
using System.Threading.Tasks;
using Telegram.Bot;
using Telegram.Bot.Exceptions;
using Telegram.Bot.Extensions.Polling;
using Telegram.Bot.Types;
using Telegram.Bot.Types.Enums;

namespace AsyncBot
{

MihaZupan

// doesn't block
void StartReceiving(Func<Update, Task> updateHandler, Func<Exception, Task> exceptionHandler);

// awaitable blocking task
async Task ReceiveAsync(Func<Update, Task> updateHandler, Func<Exception, Task>? exceptionHandler);

// calls GetUpdates after all updates are processed
async IAsyncEnumerable<Update> YieldUpdatesAsync(Func<Exception, Task>? exceptionHandler);

// keeps calling GetUpdates and enqueues updates internally, yielding them one by one

MihaZupan

public static TelegramBotClient Bot;

public static async Task Main()
{
    Bot = new TelegramBotClient("");

    // Note: HandleExceptionAsync is optional (except on StartReceiving)

    // awaitable blocking task
    await Bot.ReceiveAsync(HandleUpdateAsync, HandleExceptionAsync);

MihaZupan

using System.Collections.Immutable;
using System.Composition;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.CodeAnalysis;
using Microsoft.CodeAnalysis.CodeActions;
using Microsoft.CodeAnalysis.CodeFixes;
using Microsoft.CodeAnalysis.CSharp.Syntax;
using Microsoft.CodeAnalysis.Diagnostics;