rogeralsing

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

namespace ConsoleApplication1
{

rogeralsing

public class ConcurrentQueueMailbox : Mailbox
{
    private ConcurrentQueue<Envelope> userMessages = new ConcurrentQueue<Envelope>();
    private ConcurrentQueue<Envelope> systemMessages = new ConcurrentQueue<Envelope>();
    
    private WaitCallback run = null;
    public ConcurrentQueueMailbox()
    {            
        run = new WaitCallback(_ =>
        {

rogeralsing

public class Mailbox
{
    private ConcurrentQueue<Envelope> queue = new ConcurrentQueue<Envelope>();

    private int scheduled = 0;
    private volatile bool hasUnScheduledMessages = false;
    private WaitCallback run;

    public Mailbox ()
    {

rogeralsing

public class Mailbox
{
    private static class MailboxStatus
    {
        public const int Idle = 0;
        public const int Busy = 1;
    }

    private readonly ConcurrentQueue<Envelope> _queue = new ConcurrentQueue<Envelope>();
    private volatile bool _hasUnScheduledMessages;

rogeralsing

public static class ThreadPoolGuardian
{
    private static readonly BlockingCollection<Guard> guards = new BlockingCollection<Guard>();

    public static void Queue(Action action)
    {
        Action wrapper = () =>
        {
            var guard = new Guard
            {

rogeralsing

using System;
using System.Collections.Generic;
using System.Text;

namespace ConfigParser
{
    internal class Program
    {
        private static void Main(string[] args)
        {

rogeralsing

var chatMessages = GetObservableOfChatMessages();
var chatIsIdle = chatMessages. _dontknow_ (TimeSpan.FromSeconds(5));

chatMessages.Subscribe (msg => Console.WriteLine("{0} says: {1}",msg.User,msg.Text));

//I want this to occur every time the chatmessages observable have been silent for 5 sec
//not just once
chatIsIdle.Subscribe ( ... => Console.WriteLine("Chat is idle...");

rogeralsing

public class Foo<T> where T: IDoStuff
{
  private T _stuffer;
  
  public Foo(T stuffer)
  {
    _stuffer = stuffer;
  }
  
  public void Bar()

rogeralsing

using System;
using System.Diagnostics;
using System.Linq;
using System.Linq.Expressions;
using System.Reflection;

namespace ConsoleApplication10
{
    internal delegate T ObjectActivator<out T>(params object[] args);

rogeralsing

using System;
using System.Threading.Tasks;
using Akka.Actor;
using Akka.TestKit;
using Xunit;

namespace Akka.Tests.Dispatch
{
    public class AsyncAwaitActor : ReceiveActor
    {