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

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

mookid8000

public class SomeDoc : Doc
{
    public Ref<AnotherDoc> TheOtherDoc { get; set; }
}

public class AnotherDoc : Doc
{
    public string Text { get; set; }
}

mookid8000

Configure.With(...)
    .Transport(t => t.UseRabbitMq(...)  //< giver en RabbitMqOptions
                   .PrefetchCount(5))