加密+泵的自定義數據源具有StringSource,ArraySource,FileSource等能夠從ByteQueue
但是我需要使用源類可以從ByteQueue用於將來通過濾和水槽獲取數據。
即:
_QUEUE_Source(MyPreparedQueue, true,
new HashFilter(hash,
new FileSink(zOutputFile),
true));
我如何能做到這一點,W/O發送到MyPreparedQueue的ArraySource額外的中間存儲緩衝器和選擇的?