要使用在流水线上生产出来的数据可以使用 Stream 提供的 .listen 这个方法,就是去监听,或者叫订阅一下流水线。这里 vehicleStream 是一个 Stream,所以我们可以使用它上面的 listen 这个方法。
给它提供一个函数参数,可以决定如何使用流水线上生产出来的数据,函数有个 data,它的值就是流水线上出来的数据,这里我们可以用 print 把它输出到控制台上检查一下。
运行一下应用,等待三秒钟,vehicleStream 会生产出来一个数据,我们订阅了流水线,设置了当有数据出来的时候就把它输出到控制台上,所以这里你会发现这个表情符号。