这里为了使代码更加简洁,直接用了transfer来挂接两路流的传输操作。

    1. // 初始化文件输入流
    2. tb_stream_ref_t istream = tb_stream_init_from_url("/home/file.txt");
    3.  
    4. // 初始化文件输出流
    5. tb_stream_ref_t ostream = tb_stream_init_from_file("/home/file.gz", TB_FILE_MODE_RW | TB_FILE_MODE_CREAT | TB_FILE_MODE_BINARY | TB_FILE_MODE_TRUNC);
    6.  
    7. // 初始化解压缩流,以istream作为输入
    8. tb_stream_ref_t fstream = tb_stream_init_filter_from_zip(istream, TB_ZIP_ALGO_GZIP, TB_ZIP_ACTION_INFLATE);
    9.  
    10. // 初始化压缩流,以istream作为输入
    11. //tb_stream_ref_t fstream = tb_stream_init_filter_from_zip(istream, TB_ZIP_ALGO_GZIP, TB_ZIP_ACTION_DEFLATE);
    12.  
    13. // 进行流传输,并且通过 fstream进行中间外挂解压、压缩
    14. if (istream && ostream && fstream)
    15. {
    16. /* 保存流数据,如果每个流都还没有调用tb_stream_open打开过
    17. * 这里会自动帮你打开,这样上层接口使用上,看上去更加简洁明了
    18. *
    19. * 后面三个参数主要用于:限速、进度信息回调,这些之后再详细说明
    20. * 现在只需要传空就行了
    21. *
    22. * save 是 实际传输的数据大小,失败返回:-1
    23. */
    24. tb_hong_t save = tb_transfer_done(fstream, ostream, 0, tb_null, tb_null);
    25. }
    26.  
    27. // 释放流数据
    28. if (fstream) tb_stream_exit(fstream);
    29. if (istream) tb_stream_exit(istream);
    30. if (ostream) tb_stream_exit(ostream);