MCPcopy Create free account
hub / github.com/brimdata/super / WriteControl

Method WriteControl

api/queryio/writer.go:84–96  ·  view source on GitHub ↗
(value any)

Source from the content-addressed store, hash-verified

82}
83
84func (w *Writer) WriteControl(value any) error {
85 if !w.ctrl {
86 return nil
87 }
88 var err error
89 if ctrl, ok := w.writer.(controlWriter); ok {
90 err = ctrl.WriteControl(value)
91 if w.flusher != nil {
92 w.flusher.Flush()
93 }
94 }
95 return err
96}
97
98func (w *Writer) Close() error {
99 return w.writer.Close()

Callers 4

WriteBatchMethod · 0.95
WhiteChannelEndMethod · 0.95
WriteProgressMethod · 0.95
WriteErrorMethod · 0.95

Calls 2

WriteControlMethod · 0.65
FlushMethod · 0.45

Tested by

no test coverage detected