Class StreamingPipeDocUploadService

java.lang.Object

ai.pipeline.connector.intake.pipedoc.streaming.StreamingPipeDocUploadService

@ApplicationScoped
public class StreamingPipeDocUploadService
extends Object

Constructor Summary

Constructors

Constructor	Description
StreamingPipeDocUploadService()

Method Summary

Modifier and Type	Method	Description
io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest>	open(io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamResponse> responseObserver)

Methods inherited from class Object

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

Constructor Details

StreamingPipeDocUploadService

public StreamingPipeDocUploadService()

Method Details

open

public io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest> open(io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamResponse> responseObserver)