Struct QObjectStream

flow/model/qobject_stream.go:33–40

QObjectStream is a stream of HTTP objects represented with URLs that are directly consumable by any HTTP client when combined with authentication headers from the HeaderProvider.

// that are directly consumable by any HTTP client when combined
// with authentication headers from the HeaderProvider.
type QObjectStream struct {
	Objects             chan *Object
	formatLatch         *concurrency.Latch[QObjectStreamFormat]
	schemaLatch         *concurrency.Latch[types.QRecordSchema]
	headerProviderLatch *concurrency.Latch[HeaderProvider]
	err                 error
	closeOnce           sync.Once
}

func NewQObjectStream(buffer int) *QObjectStream {
	return &QObjectStream{