We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
The Sink trait expects to return resumption state
Sink
async fn get_resumption_state(&mut self) -> Result<PipelineResumptionState, SinkError>; but right now properties of the struct are set to private.
async fn get_resumption_state(&mut self) -> Result<PipelineResumptionState, SinkError>;
Try to use any custom sink with the pipeline
Must be able to implement custom sinks
The text was updated successfully, but these errors were encountered:
Fix in #61 merged.
Sorry, something went wrong.
No branches or pull requests
Bug report
Describe the bug
The
Sink
trait expects to return resumption stateasync fn get_resumption_state(&mut self) -> Result<PipelineResumptionState, SinkError>;
but right now properties of the struct are set to private.To Reproduce
Try to use any custom sink with the pipeline
Expected behavior
Must be able to implement custom sinks
The text was updated successfully, but these errors were encountered: