Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RoundTripReader ¶ added in v0.4.1
type RoundTripReader struct {
// contains filtered or unexported fields
}
RoundTripReader is a reader implementation that allows you to define a closure for producing messages and another for processing the result.
The mechanism for receiving results is implemented using a ResultStore, and therefore is subject to pipelines that preserve context and one or more outputs destinations storing their results.
func NewRoundTripReader ¶ added in v0.4.1
func NewRoundTripReader( read func() (types.Message, error), processResults func([]types.Message, error), ) *RoundTripReader
NewRoundTripReader returns a RoundTripReader.
func (*RoundTripReader) Acknowledge ¶ added in v0.4.1
func (f *RoundTripReader) Acknowledge(err error) error
Acknowledge is a noop.
func (*RoundTripReader) CloseAsync ¶ added in v0.4.1
func (f *RoundTripReader) CloseAsync()
CloseAsync is a noop.
func (*RoundTripReader) Connect ¶ added in v0.4.1
func (f *RoundTripReader) Connect() error
Connect is a noop.
func (*RoundTripReader) Read ¶ added in v0.4.1
func (f *RoundTripReader) Read() (types.Message, error)
Read returns a message result from the provided closure.
func (*RoundTripReader) WaitForClose ¶ added in v0.4.1
func (f *RoundTripReader) WaitForClose(time.Duration) error
WaitForClose is a noop.
Source Files
Click to show internal directories.
Click to hide internal directories.