stream

type Stream[T any] interface {
	// Connect 建立连接并开始数据流接收。
	// cfg: 配置参数（任意类型），具体实现在接收cfg后根据交易所要求建立连接。
	Connect(ctx context.Context, cfg T) error

	// ID 返回该Stream的唯一ID，这个ID是在Connect时由调用方传入并存储下来的。
	ID() string

	// Disconnect 关闭连接并停止接收数据。
	Disconnect() error

	// Type 返回该Stream的类型
	Type() types.StreamType
}