PipelineMessage

constructor(checkpointCounts: Map<CheckpointId, CheckpointValue>, key: K, value: T, postProcessingCallback: suspend () -> Unit? = null, context: PipelineContext? = null)