Page History

...

일치하며 실제로 그래프와 동일하게 작동됩니다. 

Fan-in/out 처리

...

• Fan-out

  • Broadcast<T> – (1 input, N outputs) given an input element emits to each output
  • Balance<T> – (1 input, N outputs) given an input element emits to one of its output ports
  • UnzipWith<In,A,B,...> – (1 input, N outputs) takes a function of 1 input that given a value for each input emits N output elements (where N <= 20)
  • UnZip<A,B> – (1 input, 2 outputs) splits a stream of (A,B) tuples into two streams, one of type Aand one of type B

• Fan-in

  • Merge<In> – (N inputs , 1 output) picks randomly from inputs pushing them one by one to its output
  • MergePreferred<In> – like Merge but if elements are available on preferred port, it picks from it, otherwise randomly from others
  • MergePrioritized<In> – like Merge but if elements are available on all input ports, it picks from them randomly based on their priority
  • ZipWith<A,B,...,Out> – (N inputs, 1 output) which takes a function of N inputs that given a value for each input emits 1 output element
  • Zip<A,B> – (2 inputs, 1 output) is a ZipWith specialised to zipping input streams of A and B into an (A,B) tuple stream
  • Concat<A> – (2 inputs, 1 output) concatenates two streams (first consume one, then the second one)