pagination

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

type IIterator interface {
	// HasNext returns whether there are more items available or not.
	HasNext() bool
	// GetNext returns the next item.
	GetNext() (*interface{}, error)
}

type IPage interface {
	// HasNext states whether more pages are accessible.
	HasNext() bool
	// GetNext returns the next page.
	GetNext(ctx context.Context) (IPage, error)
	// GetItemIterator returns an iterator over the page's items.
	GetItemIterator() (IIterator, error)
	// GetItemCount returns the number of items in this page
	GetItemCount() (int64, error)
}

type IPaginator interface {
	io.Closer
	IIterator
	// Stop returns a stop function which stops the iteration.
	Stop() context.CancelFunc
	// GetCurrentPage returns the current page.
	GetCurrentPage() (IPage, error)
}

type IStream interface {
	IPage
	// HasFuture states whether there may be future items.
	HasFuture() bool
	// GetFuture returns the future page.
	GetFuture(ctx context.Context) (IPage, error)
}

type IStreamPaginator interface {
	IPaginator
	// DryUp indicates to the stream that it will soon run out.
	DryUp() error
	// IsRunningDry indicates whether the stream is about to run out.
	IsRunningDry() bool
}

type MockItem struct {
	Index  int
	ID     string
	Value1 string
	Value2 string
}

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

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

type StreamPaginator struct {
	AbstractPaginator
	// contains filtered or unexported fields
}