go-streams 缓存示范

下面是一个使用 go-streams 缓存的示例：

package main

import (
    "fmt"
    "time"

    "github.com/reugn/go-streams/flow"
    "github.com/reugn/go-streams/producer"
)

func main() {
    // 创建一个缓存流
    cache := flow.NewCache(5, time.Second*10)

    // 创建一个生产者流，生成 1 到 10 的数字
    producer := producer.NewSliceProducer([]interface{}{1, 2, 3, 4, 5, 6, 7, 8, 9, 10})

    // 创建一个流，将数据传递到缓存流中
    pipeline := flow.NewPipeline(
        producer,
        cache,
    )

    // 遍历缓存流中的数据并打印
    for data := range cache.Out() {
        fmt.Println(data)
    }

    // 关闭流
    pipeline.Stop()
}

在这个示例中，我们使用 `flow.NewCache()` 创建了一个缓存流，并设置了缓存的大小为 5，缓存的有效期为 10 秒。

然后我们创建了一个生产者流，生成数字 1 到 10，并将数据传递到缓存流中。

最后我们遍历缓存流中的数据并打印出来。

需要注意的是，我们必须在流处理完毕后手动调用 `pipeline.Stop()` 来关闭流。