Package ai.pipestream.connector.intake.pipedoc.streaming

package ai.pipestream.connector.intake.pipedoc.streaming

Related Packages

Package	Description
ai.pipestream.connector.intake.pipedoc

Classes

Class	Description
DocumentDeleteEmitter	Publishes the intake layer's broadcast DocumentDeleted signal to Kafka.
StreamingPipeDocObserver	Serializes one bidi UploadPipeDocStream call onto a small mailbox.
StreamingPipeDocUploadService