datasystem.stream_client.Producer

datasystem.stream_client.Producer#

class datasystem.stream_client.Producer(producer)#

流缓存生产者。

参数:
  • producer: - 持有producer指针的对象。

输出:

Producer

send

生产者发送数据。

close

关闭生产者。一旦关闭后,生产者不可再用。