transports

package

v1.9.2 Latest Latest Go to latest Published: Nov 16, 2025 License: MPL-2.0 Imports: 1 Imported by: 2

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type ChannelStreamResult struct {
	// contains filtered or unexported fields
}

ChannelStreamResult adapts a <-chan any into a StreamResult.

func (sr *ChannelStreamResult) Close() error

Close invokes the provided close function to terminate the stream.

func (sr *ChannelStreamResult) Next() (any, error)

Next returns the next element from the channel or io.EOF if closed.

type SliceStreamResult struct {
	// contains filtered or unexported fields
}

func NewSliceStreamResult(items []any, closeFn func() error) *SliceStreamResult

func (sr *SliceStreamResult) Close() error

func (sr *SliceStreamResult) Next() (any, error)

type StreamResult interface {
	Next() (interface{}, error)
	Close() error
}

func NewChannelStreamResult(ch <-chan any, closeFn func() error) StreamResult

NewChannelStreamResult constructs a StreamResult from a channel and a close function.