Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InputStreamer ¶
type InputStreamer struct {
Names []string // input filenames
// contains filtered or unexported fields
}
InputStreamer reads data from a (set of) rio-stream(s)
func (*InputStreamer) Connect ¶
func (input *InputStreamer) Connect(ports []fwk.Port) error
func (*InputStreamer) Disconnect ¶
func (input *InputStreamer) Disconnect() error
func (*InputStreamer) Read ¶
func (input *InputStreamer) Read(ctx fwk.Context) error
type OutputStreamer ¶
type OutputStreamer struct {
Name string // output filename
// contains filtered or unexported fields
}
OutputStreamer writes data to a rio-stream.
func (*OutputStreamer) Connect ¶
func (o *OutputStreamer) Connect(ports []fwk.Port) error
func (*OutputStreamer) Disconnect ¶
func (o *OutputStreamer) Disconnect() error
func (*OutputStreamer) Write ¶
func (o *OutputStreamer) Write(ctx fwk.Context) error
Source Files
Click to show internal directories.
Click to hide internal directories.