(mbw *mixedbatchwriter.MixedBatchWriter)
| 265 | } |
| 266 | |
| 267 | func adaptMixedBatchWriter(mbw *mixedbatchwriter.MixedBatchWriter) adaptedMixedBatchWriter { |
| 268 | return adaptedMixedBatchWriter{ |
| 269 | mbw: mbw, |
| 270 | } |
| 271 | } |
| 272 | |
| 273 | func (a adaptedMixedBatchWriter) Write(ctx context.Context, messages <-chan message.WriteMessage) error { |
| 274 | return a.mbw.Write(ctx, messages) |