Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Chunk ¶
func (*Chunk) ToMarshalable ¶
func (rc *Chunk) ToMarshalable() ChunkMarshalable
type ChunkMarshalable ¶
type ContentAccumulator ¶
type ContentAccumulator struct {
Response types.Response
// contains filtered or unexported fields
}
func NewContentAccumulator ¶
func NewContentAccumulator() ContentAccumulator
func (*ContentAccumulator) AddChunk ¶
func (acc *ContentAccumulator) AddChunk(chunk *types.Response) error
func (ContentAccumulator) HasFinished ¶
func (acc ContentAccumulator) HasFinished() bool
type ErrChunkAddition ¶
func (ErrChunkAddition) Error ¶
func (e ErrChunkAddition) Error() string
type ResponseChannel ¶
type ResponseChannel chan Chunk
func NewResponseChannel ¶
func NewResponseChannel(size ...int) ResponseChannel
func (ResponseChannel) Close ¶
func (rs ResponseChannel) Close()
func (ResponseChannel) Drain ¶
func (rs ResponseChannel) Drain() int
func (ResponseChannel) Send ¶
func (rs ResponseChannel) Send(data *types.Response)
func (ResponseChannel) SendErr ¶
func (rs ResponseChannel) SendErr(err error)
Click to show internal directories.
Click to hide internal directories.