valerysntx

public struct FromAsyncTaskResult{
   public int result;
};

void Main(){
  MainNew().GetAwaiter().GetResult();
}

async Task<FromAsyncTaskResult[]> MainNew()
{

valerysntx

   public class ProducerConsumerQueue : IDisposable
    {
      /// <summary>
      /// thread blocking collection 
      /// </summary>
      BlockingCollection<WorkItem> taskCollection = new BlockingCollection<WorkItem>();


      /// <summary>
      /// task continuations and 

valerysntx

/* Reactive Cloud Queue */



namespace AzureTrader.Messaging
{
    
    using System;
    using System.Collections;
    using System.Collections.Generic;

valerysntx

async Task Main()
{
	using (var q = new CommandsPipeline(2))
	{
    await Task.Run(()=> {
      var queue = q;
      Parallel.ForEach(string.Format("StringParallelQuery"),
        new ParallelOptions { 

valerysntx

<?xml version="1.0" encoding="utf-8" ?>
<Weavers>
  <Costura>
    <CreateTemporaryAssemblies>
      True
    </CreateTemporaryAssemblies>
    <ExcludeAssemblies>
      System
      System.Core
    </ExcludeAssemblies>

valerysntx

void Main()
{
  
  using(var kernel = new StandardKernel())
  {
      kernel.Bind<Foo>().ToSelf();
      kernel.Bind<IBarFactory>().To<BarFactory>();
      kernel.Bind<Bar>().ToSelf();
  
      kernel.Get<Foo>().Do(1,2);

valerysntx

using System;
using System.Reflection;
using System.Linq.Expressions;
using System.Collections;
using System.Linq;

public class Program
{
	public static void Main()
	{

valerysntx

using System;
using System.Threading.Tasks;

namespace AsyncReadWritePipeline
{
    public class Program
    {
        public class ProducerConsumerHub<T>
        {
            TaskCompletionSource<Empty> _consumer = new TaskCompletionSource<Empty>();

valerysntx

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using GenericMsmqProcessing.Core.MessageHandler;
using GenericMsmqProcessing.Core.Queue;
using log4net;

namespace GenericMsmqProcessing.Core.MessageProccessor

valerysntx

    member x.ToMsmqQueuePath() =
        match x with
        | LocalName(hostName, queueName)-> (sprintf @".\private$\%s" queueName)
        | IPAddress(hostName, queueName)-> (sprintf @"FormatName:DIRECT=TCP:%s\private$\%s" hostName queueName)
        | Multicast(hostName, port)-> (sprintf @"FormatName:MULTICAST=%s:%i" hostName port)
        | MachineId(hostName, queueName)-> (sprintf @"FormatName:PRIVATE=%s\%s" hostName queueName)
        | _-> (sprintf @"FormatName:DIRECT=OS:%s\private$\%s" x.Host(getQueueName x))