Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StreamHandler ¶
type StreamHandler struct {
// contains filtered or unexported fields
}
func (*StreamHandler) Continue ¶
func (p *StreamHandler) Continue()
Continue tells the handler to resume the processing of the current stream.
func (*StreamHandler) Errors ¶
func (p *StreamHandler) Errors() <-chan error
Errors gives a channel where all errors are sent to.
func (*StreamHandler) Finished ¶
func (p *StreamHandler) Finished() <-chan struct{}
Finished returns a channel that is used to signal that the handler is done processing the current stream.
func (*StreamHandler) Pause ¶
func (p *StreamHandler) Pause()
Pause tells the handler to pause the processing of the current stream.
func (*StreamHandler) Play ¶
func (p *StreamHandler) Play(iostream io.Reader) error
Play starts processing the stream.
func (*StreamHandler) Stop ¶
func (p *StreamHandler) Stop()
Stop tells the handler to stop processing the current stream.
Source Files
Click to show internal directories.
Click to hide internal directories.