implstream

Documentation

Index

• type MockStream
  • func NewDefaultStream(partition int, nElems int) *MockStream
  • func NewMock(items [][]byte) *MockStream
  • func (m MockStream) Close() error
  • func (m *MockStream) Done(ctx context.Context) error
  • func (m MockStream) IsEmpty() bool
  • func (m *MockStream) Next(ctx context.Context) (goduck.RawMessage, error)

Types

type MockStream

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

func NewDefaultStream

func NewDefaultStream(partition int, nElems int) *MockStream

func NewMock

func NewMock(items [][]byte) *MockStream

func (MockStream) Close

func (m MockStream) Close() error

func (*MockStream) Done

func (m *MockStream) Done(ctx context.Context) error

func (MockStream) IsEmpty

func (m MockStream) IsEmpty() bool

IsEmpty tests if all elements in the queue are consumed

func (*MockStream) Next

func (m *MockStream) Next(ctx context.Context) (goduck.RawMessage, error)