mookid8000

public static class TaskExtensions
{
    public static async Task<List<TItem>> ToListAsync<TItem>(this IEnumerable<Task<TItem>> items)
    {
        var tasks = items.Select(i => i).ToArray();
        await Task.WhenAll(tasks);
        return tasks.Select(t => t.Result).ToList();
    }
}

mookid8000

rebus-org Contributor License Agreement

By agreeing to this CLA you acknowledge that you transfer ownership of the code to rebus-org. The code will then carry the same MIT license as the repository to which it was submitted.

In order to do this, you must of course have the right to do so. You acknowledge this too.

mookid8000

    public static class SubscriberCacheExtensions
    {
        public static void EnableSubscriberCache(this OptionsConfigurer configurer)
        {
            configurer.Decorate<ISubscriptionStorage>(c =>
            {
                var subscriptionStorage = c.Get<ISubscriptionStorage>();

                return new CachingSubscriptionStorage(subscriptionStorage);
            });

mookid8000

using System;
using System.Threading;
using System.Threading.Tasks;
using Rebus.Logging;

namespace Rebus.Threading
{
    /// <summary>
    /// <see cref="Task"/>-based background timer thingie, that will periodically call an async <see cref="Func&lt;Task&gt;"/>
    ///  </summary>

mookid8000

try
{
    var startableBus = Configure.With(new BuiltinContainerAdapter())
        .Logging(l => l.None())
        .Transport(t => t.UseMsmqInOneWayClientMode())
        .CreateBus();

    using (var bus = startableBus.Start())
    {
        bus.Advanced.Routing.Send("NO_CHANCE_THAT_THIS_QUEUE_EXISTS", "hello there!");

mookid8000

public async Task<HttpResponseMessage> Get()
{
    var blobClient = GetBlobClientFromSomewhere();
    var imagesContainer = blobClient.GetContainerReference("images");

    var blobRef = await imagesContainer.GetBlobReferenceFromServerAsync(@"cute_cats_70MB.jpg");

    var openRead = await blobRef.OpenReadAsync();
    
    var response = new HttpResponseMessage(HttpStatusCode.OK)

mookid8000

Action<MyDomainAssembly.ISubscribeTo<MyDomainAssembly.IDomainEvent>, MyDomainAssembly.IDomainEvent>
 dispatchSpecification = (s, e) => s.Handle(e);


Action<MyDomainAssembly.IDomainEvent> myDispatcher =
  DomainEvents.Configure.With(someIocContainerAdapter)
     .DefineSubscriberAs<MyDomainAssembly.ISubscribeTo<MyDomainAssembly.IDomainEvent>>(dispatchSpecification)
     .RegisterSubscribersFromAssemblyContaining<MyDomainAssembly.SomeConcreteSubscriber>(Lifestyle.InstancePerCall)
     .RegisterSubscribersFromAssemblyContaining<MyInfrastructureAssembly.AnotherConcreteSubscriber>(Lifestyle.InstancePerCall)
     .CreateDispatcher();

mookid8000

Configure.With(...)
         .EnableWebCallbacks()
         .(...)

// (...)

// just like that
adapter.Bus.Send(new SomeRequest {Message = "hello there!"},
                 (SomeReply reply) =>
                 {

mookid8000

sqlReplicate('SomeTable', {
  Id: documentId,
  SomeIntegerColumn: 23
});

mookid8000

public interface ILoadAggregateRoots
{
  T Load<T>(string id) where T:Doc;
}

public static class Loader
{
  static ILoadAggregateRoots currentLoader = new ThrowMustProvideLoaderException();
  
  public static ILoadAggregateRoots Current