Pipe pipe = Pipe.open();
WritableByteChannel out = pipe.sink();
ReadableByteChannel in = pipe.source();
FibonacciProducer producer = new FibonacciProducer(out, 200);
FibonacciConsumer consumer = new FibonacciConsumer(in);
producer.start();
consumer.start();