(ctx context.Context, keyType TType, valueType TType, size int)
| 252 | } |
| 253 | |
| 254 | func (p *TCompactProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error { |
| 255 | if size == 0 { |
| 256 | err := p.writeByteDirect(0) |
| 257 | return NewTProtocolException(err) |
| 258 | } |
| 259 | _, err := p.writeVarint32(int32(size)) |
| 260 | if err != nil { |
| 261 | return NewTProtocolException(err) |
| 262 | } |
| 263 | err = p.writeByteDirect(byte(p.getCompactType(keyType))<<4 | byte(p.getCompactType(valueType))) |
| 264 | return NewTProtocolException(err) |
| 265 | } |
| 266 | |
| 267 | func (p *TCompactProtocol) WriteMapEnd(ctx context.Context) error { return nil } |
| 268 |
nothing calls this directly
no test coverage detected