Package com.aserto.directory.v3

Class ImportObserver

java.lang.Object

com.aserto.directory.v3.ImportObserver

All Implemented Interfaces:

io.grpc.stub.StreamObserver<com.aserto.directory.importer.v3.ImportResponse>

public class ImportObserver
extends Object
implements io.grpc.stub.StreamObserver<com.aserto.directory.importer.v3.ImportResponse>

Constructor Summary

Constructors

Constructor	Description
ImportObserver(ImportHandler handler)

Method Summary

Modifier and Type	Method	Description
io.grpc.Status	await(long timeout, TimeUnit unit)
io.grpc.Status	getStatus()
void	onCompleted()
void	onError(Throwable throwable)
void	onNext(com.aserto.directory.importer.v3.ImportResponse importResponse)

Methods inherited from class java.lang.Object

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

Constructor Details

ImportObserver

public ImportObserver(ImportHandler handler)

Method Details

getStatus

public io.grpc.Status getStatus()

await

public io.grpc.Status await(long timeout,
 TimeUnit unit)
                     throws InterruptedException

Throws:

InterruptedException

onNext

public void onNext(com.aserto.directory.importer.v3.ImportResponse importResponse)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<com.aserto.directory.importer.v3.ImportResponse>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface io.grpc.stub.StreamObserver<com.aserto.directory.importer.v3.ImportResponse>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<com.aserto.directory.importer.v3.ImportResponse>