Producer(Source)、Filtersの連続適用、Exporterの書き出し──この3ステップを順番にハイライトします。 ChannelやCancellationTokenがどこで効いているか、ステップごとのメモで確認してください。