package Ġre agent . source Ċ Ċ import Ġre agent . Task Ċ Ċ interface ĠTask Creator < out ĠI > Ġ{ ĊĠ Ġfun Ġsubscribe ( down stream : ĠDown stream < I >) ĊĊĠ Ġinterface ĠDown stream < in ĠI > Ġ: ĠTask . Observer < I > Ġ{ ĊĠĠĠ Ġval Ġis Disposed : ĠBoolean ĊĠ Ġ} Ċ } ĊĊ