recordUploadCompleter

@Named(value = "recordUploadCompleterStep")
@Singleton
fun <K : WithStream, T : RemoteObject<*>> recordUploadCompleter(objectLoader: ObjectLoader, uploadCompleter: ObjectLoaderUploadCompleter<T>, @Named(value = "objectLoaderLoadedPartQueue") inputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartLoader.PartResult<T>>>, @Named(value = "objectLoaderCompletedUploadQueue") completedUploadQueue: PartitionedQueue<PipelineEvent<K, ObjectLoaderUploadCompleter.UploadResult<T>>>? = null, completedUploadPartitioner: ObjectLoaderCompletedUploadPartitioner<ObjectKey, ObjectLoaderPartLoader.PartResult<T>, K, T>? = null, taskFactory: LoadPipelineStepTaskFactory): ObjectLoaderUploadCompleterStep<K, T>