Documentation
¶
Overview ¶
Provides a composable data stream, which pipes multiple inputs to multiple outputs according to the defined compositions
Index ¶
- type ComposableDataStream
- func (stream *ComposableDataStream) Bytes() []byte
- func (stream *ComposableDataStream) Close()
- func (stream *ComposableDataStream) Closed() bool
- func (stream *ComposableDataStream) Completed() bool
- func (stream *ComposableDataStream) Copy() io.Reader
- func (stream *ComposableDataStream) CopyOrResult() io.Reader
- func (stream *ComposableDataStream) Intercept() io.ReadWriteCloser
- func (stream *ComposableDataStream) Len() int
- func (stream *ComposableDataStream) MergeWith(newReader io.Reader)
- func (stream *ComposableDataStream) Replace(reader io.Reader)
- func (stream *ComposableDataStream) StartCopyingInto(writer io.Writer)
- func (stream *ComposableDataStream) String() string
- func (stream *ComposableDataStream) Wait()
- func (stream *ComposableDataStream) WriteCloser() io.WriteCloser
- type ComposableDataStreamIntercept
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ComposableDataStream ¶
type ComposableDataStream struct {
Name string
// contains filtered or unexported fields
}
func NewClosedComposableDataStreamFromBuffer ¶
func NewClosedComposableDataStreamFromBuffer(buffer *bytes.Buffer) *ComposableDataStream
func NewComposableDataStream ¶
func NewComposableDataStream(name string, errorHandler func(error)) *ComposableDataStream
func (*ComposableDataStream) Bytes ¶
func (stream *ComposableDataStream) Bytes() []byte
func (*ComposableDataStream) Close ¶
func (stream *ComposableDataStream) Close()
func (*ComposableDataStream) Closed ¶
func (stream *ComposableDataStream) Closed() bool
func (*ComposableDataStream) Completed ¶
func (stream *ComposableDataStream) Completed() bool
func (*ComposableDataStream) Copy ¶
func (stream *ComposableDataStream) Copy() io.Reader
func (*ComposableDataStream) CopyOrResult ¶
func (stream *ComposableDataStream) CopyOrResult() io.Reader
func (*ComposableDataStream) Intercept ¶
func (stream *ComposableDataStream) Intercept() io.ReadWriteCloser
func (*ComposableDataStream) Len ¶
func (stream *ComposableDataStream) Len() int
func (*ComposableDataStream) MergeWith ¶
func (stream *ComposableDataStream) MergeWith(newReader io.Reader)
func (*ComposableDataStream) Replace ¶
func (stream *ComposableDataStream) Replace(reader io.Reader)
func (*ComposableDataStream) StartCopyingInto ¶
func (stream *ComposableDataStream) StartCopyingInto(writer io.Writer)
func (*ComposableDataStream) String ¶
func (stream *ComposableDataStream) String() string
func (*ComposableDataStream) Wait ¶
func (stream *ComposableDataStream) Wait()
func (*ComposableDataStream) WriteCloser ¶
func (stream *ComposableDataStream) WriteCloser() io.WriteCloser
type ComposableDataStreamIntercept ¶
type ComposableDataStreamIntercept struct {
// contains filtered or unexported fields
}
func NewComposableDataStreamIntercept ¶
func NewComposableDataStreamIntercept(reader io.Reader, writer io.WriteCloser, errorHandler func(error)) *ComposableDataStreamIntercept
func (*ComposableDataStreamIntercept) Close ¶
func (intercept *ComposableDataStreamIntercept) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.