Acapla

public class AwaitableQueue<T>
{
    private readonly ConcurrentQueue<T> _queue = new ConcurrentQueue<T>();
    private long _count = 0;
    private readonly ConcurrentQueue<TaskCompletionSource<T>> _pending = new ConcurrentQueue<TaskCompletionSource<T>>();

    /// <summary>
    /// Enqueue the specified item. Blocking operation.
    /// </summary>
    /// <param name="item">Item.</param>

Acapla

    public class EventMessage
    {
        public int What;
        public int Arg0;
        public int Arg1;
        public object Obj1;
        public Action<EventMessage> Handler;
    }

    /// <summary>

Acapla

    public class Queue<T>
    {
        private readonly ConcurrentQueue<T> _queue = new ConcurrentQueue<T>();
        private long _count = 0;
        private readonly Action<T> _action = null;

        public Queue(Action<T> action)
        {
            _action = action;
        }

Acapla

import yaml

class Message():
    __start_mark = '{'
    __end_mark = '}'

    __item_tag = 'item'
    __order_tag = 'order'
    __hyperlink_types = [__order_tag, __item_tag]

Acapla

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;


namespace SomeRandomTest
{
    class Program