/*

​

[Generator]  ->     [Distributor]  ->  [ClientServiceA]

​

                                    ->   [ClientServiceB]

                                      ->   [ClientServiceC]

​

​

Task: Implement _ only_ the “Distributor” functionality for a service which generate’s orders.

​

​

Generator : Provides real time updates of objects type “ItemA”, “ItemB” and “ItemC”.

​

Distributor : Receives updates from ‘Generator’ and identify the type of object and distributes it to the appropriate ‘Client’. So ItemA only gets distributed to ClientA. ItemB only gets distributed ClientB and so on.

​

Note:

​

‘ Generator’ should not get blocked while processing the object in Distributor.

If Service performs faster than distributor then distributor should throttle the items.

There should not be any delay while receiving the items at ClientA, ClientB, ClientC

Consider unit testing (TDD)

Interfaces:

​

Generator.NewItem (event)

Distributor reads from Generator.NewItem event

*/

​

using System;

​

​

public class Program

​

{

​

 public static void Main()

​

 {

​

  // If possible, consider unit tests

​

// (using whatever mechanism you like, example, below) 

​

  new UnitTests().PerformUnitTest();

​

 }

​

}

​

​

public interface IItem { Object Data {get;set;}}

​

public class Item : IItem { public Object Data {get;set;}}

​

public class ItemA : Item {}

​

public class ItemB : Item {}

​

public class ItemC : Item {}

​

​

public interface IGenerator

​

{

​

 event EventHandler<IItem> NewItem;

​

}

​

​

public class Distributor

​

{

​

 // Add code to implement the distributor

​

}

​

​

public class ClientServiceA

​

{

​

 // Add something to handle the processing

​

}

​

public class ClientServiceB

​

{

​

 // Add something to handle the processing

​

}

​

public class ClientServiceC

​

{

​

 // Add something to handle the processing

​

}

​

​

​

public class UnitTests

​

{ 

​

 public void PerformUnitTest()

​

 {

​

  var sut = new Distribtutor();

​

  // Do processing

​

 }

​

​

 private void Assert(bool expected, bool actual)

​

 {

​

  if (actual != expected)

​

  {

​

   throw new Exception("Failure");

​

  }

​

 }

​

}