Graph.cs

   class Program
    {
       static void Main(string[] args)
       {
            var virtualBroker = new VirtualBroker();
            var coolStrategy = new CoolStrategy();
            var anotherCoolStrategy = new AnotherCoolStrategy();
            var graph = RunnableGraph.FromGraph(GraphDsl.Create(b =>
            {
              var input = b.Add(Source.From(new[] { new TickData(11, 12), new TickData(12, 13) })); //FAIL- Must be dynamic Queue
              var processor1 = Flow.Create<TickData>().Select(tick => coolStrategy.ProcessTickData(tick));
              var processor2 = Flow.Create<TickData>().Select(tick => anotherCoolStrategy.ProcessTickData(tick));
              var sink = Sink.Create<OrderRequest[]>().PreMaterialize(materializer).virtualBroker.ProcessOrders(ors)); // FAIL 
              return ClosedShape.Instance;
          }));
        }
        
        public class CoolStrategy
        {
            public OrderRequest ProcessTickData(TickData tickData)
            {
                throw new NotImplementedException();
            }
        }

        public class AnotherCoolStrategy
        {
            public OrderRequest ProcessTickData(TickData tickData)
            {
                throw new NotImplementedException();
            }
        }

        public class VirtualBroker
        {
            public void ProcessOrders(OrderRequest[] orderRequests)
            {

            }
        } 
        
      }