Currently, flow.Sink is just an io.WriteCloser which is convenient but not ideal for a lot of use cases because the Close method doesn't accept a context.Context.
Most sinks (GCS and S3Compat come to mind) write their contents when they are closed but we have no way of signaling/canceling these operations.
Do we want to:
- Make our own interface that accepts a context on close?
- Redesign the sinks to not write their data on close?
- Something else I haven't thought of?
Currently,
flow.Sinkis just anio.WriteCloserwhich is convenient but not ideal for a lot of use cases because theClosemethod doesn't accept acontext.Context.Most sinks (GCS and S3Compat come to mind) write their contents when they are closed but we have no way of signaling/canceling these operations.
Do we want to: