Class StreamingPipeDocObserver

java.lang.Object

ai.pipeline.connector.intake.pipedoc.streaming.StreamingPipeDocObserver

All Implemented Interfaces:

io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest>

public class StreamingPipeDocObserver
extends Object
implements io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest>

Serializes one bidi UploadPipeDocStream call onto a small mailbox.

The gRPC transport can deliver cancellation, request messages, and completion callbacks from different threads. This observer turns those events into one ordered stream processed by a virtual-thread worker, so context validation, per-item admission, and response writes happen in a predictable sequence. Manual inbound flow control keeps at most a small number of unprocessed stream events in memory.

Constructor Summary

Constructors

Constructor	Description
StreamingPipeDocObserver(io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamResponse> responses, ConfigResolutionService configResolutionService, PipeDocAcceptanceService pipeDocAcceptanceService, DocumentDeleteEmitter documentDeleteEmitter, IntakeOutcomeRecorder outcomeRecorder, String apiKey)

Method Summary

Modifier and Type	Method	Description
void	onCompleted()
void	onError(Throwable t)
void	onNext(ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest request)
void	requestNext()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StreamingPipeDocObserver

public StreamingPipeDocObserver(io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamResponse> responses,
 ConfigResolutionService configResolutionService,
 PipeDocAcceptanceService pipeDocAcceptanceService,
 DocumentDeleteEmitter documentDeleteEmitter,
 IntakeOutcomeRecorder outcomeRecorder,
 String apiKey)

Method Details

onNext

public void onNext(ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest request)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest>

onError

public void onError(Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest>

requestNext

public void requestNext()