from mpipe import OrderedStage, Pipeline

def increment(value):
    return value + 1

def double(value):
    return value * 2

stage1 = OrderedStage(increment, 3)
stage2 = OrderedStage(double, 3)
stage1.link(stage2)
pipe = Pipeline(stage1)

for number in range(10):
    pipe.put(number)

pipe.put(None)
for result in pipe.results():
    print(result)

from mpipe import OrderedStage, Pipeline

def increment(value):
    return value + 1

def double(value):
    return value * 2

stage1 = OrderedStage(increment, 3)
stage2 = OrderedStage(double, 3)
pipe = Pipeline(stage1.link(stage2))

for number in range(10):
    pipe.put(number)

pipe.put(None)

for result in pipe.results():
    print(result)

Use multi-link pipeline construction syntax.
Use multi-link pipeline construction syntax.

  from mpipe import OrderedStage, Pipeline
  
  def increment(value):
      return value + 1
  
  def double(value):
      return value * 2
  
  stage1 = OrderedStage(increment, 3)
  stage2 = OrderedStage(double, 3)
- stage1.link(stage2)
- pipe = Pipeline(stage1)
+ pipe = Pipeline(stage1.link(stage2))
  
  for number in range(10):
      pipe.put(number)
  
  pipe.put(None)
+ 
  for result in pipe.results():
      print(result)
  
Use multi-link pipeline construction syntax.
## Code Before:
from mpipe import OrderedStage, Pipeline

def increment(value):
    return value + 1

def double(value):
    return value * 2

stage1 = OrderedStage(increment, 3)
stage2 = OrderedStage(double, 3)
stage1.link(stage2)
pipe = Pipeline(stage1)

for number in range(10):
    pipe.put(number)

pipe.put(None)
for result in pipe.results():
    print(result)

## Instruction:
Use multi-link pipeline construction syntax.
## Code After:
from mpipe import OrderedStage, Pipeline

def increment(value):
    return value + 1

def double(value):
    return value * 2

stage1 = OrderedStage(increment, 3)
stage2 = OrderedStage(double, 3)
pipe = Pipeline(stage1.link(stage2))

for number in range(10):
    pipe.put(number)

pipe.put(None)

for result in pipe.results():
    print(result)
