()
| 161 | } |
| 162 | |
| 163 | func NewPushBytesDecoder() *PushBytesDecoder { |
| 164 | return &PushBytesDecoder{dec: NewDecoder()} |
| 165 | } |
| 166 | |
| 167 | // Decode implements GeneratorCodec. |
| 168 | func (d *PushBytesDecoder) Decode(data []byte) (iter.Seq2[*tempopb.PushSpansRequest, error], error) { |