Versions in this module Expand all Collapse all v3 v3.0.2 Jun 15, 2021 v3.0.1 Jun 6, 2021 Changes in this version + type FileReceiver struct + func (fr *FileReceiver) Finalize() error + func (fr *FileReceiver) Init(msg proto.Message) error + func (fr *FileReceiver) Push(data []byte, metadata proto.Message) error + type FileStreamer struct + func (fs *FileStreamer) Finalize() error + func (fs *FileStreamer) GetNext() ([]byte, proto.Message, error) + func (fs *FileStreamer) HasNext() bool + func (fs *FileStreamer) Init(msg proto.Message) error
Go to main page