Package io.grpc.protobuf.services

Class ProtoReflectionServiceV1.ProtoReflectionStreamObserver

java.lang.Object

io.grpc.protobuf.services.ProtoReflectionServiceV1.ProtoReflectionStreamObserver

All Implemented Interfaces:

StreamObserver<ServerReflectionRequest>, Runnable

Enclosing class:

ProtoReflectionServiceV1

private static class ProtoReflectionServiceV1.ProtoReflectionStreamObserver
extends Object
implements Runnable, StreamObserver<ServerReflectionRequest>

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closeAfterSend
private ServerReflectionRequest	request
private final ServerCallStreamObserver<ServerReflectionResponse>	serverCallStreamObserver
private final ProtoReflectionServiceV1.ServerReflectionIndex	serverReflectionIndex

Constructor Summary

Constructors

Constructor	Description
ProtoReflectionStreamObserver(ProtoReflectionServiceV1.ServerReflectionIndex serverReflectionIndex, ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver)

Method Summary

Modifier and Type	Method	Description
private ServerReflectionResponse	createServerReflectionResponse(ServerReflectionRequest request, com.google.protobuf.Descriptors.FileDescriptor fd)
private void	getAllExtensions(ServerReflectionRequest request)
private void	getFileByExtension(ServerReflectionRequest request)
private void	getFileByName(ServerReflectionRequest request)
private void	getFileContainingSymbol(ServerReflectionRequest request)
private void	handleReflectionRequest()
private void	listServices(ServerReflectionRequest request)
void	onCompleted()	Receives a notification of successful stream completion.
void	onError(Throwable cause)	Receives a terminating error from the stream.
void	onNext(ServerReflectionRequest request)	Receives a value from the stream.
void	run()
private void	sendErrorResponse(ServerReflectionRequest request, Status.Code code, String message)

Methods inherited from class java.lang.Object

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

Field Details

serverReflectionIndex

private final ProtoReflectionServiceV1.ServerReflectionIndex serverReflectionIndex

serverCallStreamObserver

private final ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver

closeAfterSend

private boolean closeAfterSend

request

private ServerReflectionRequest request

Constructor Details

ProtoReflectionStreamObserver

ProtoReflectionStreamObserver(ProtoReflectionServiceV1.ServerReflectionIndex serverReflectionIndex,
 ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver)

Method Details

run

public void run()

Specified by:

run in interface Runnable

onNext

public void onNext(ServerReflectionRequest request)

Description copied from interface: StreamObserver

Receives a value from the stream.

Can be called many times but is never called after StreamObserver.onError(Throwable) or StreamObserver.onCompleted() are called.

Unary calls must invoke onNext at most once. Clients may invoke onNext at most once for server streaming calls, but may receive many onNext callbacks. Servers may invoke onNext at most once for client streaming calls, but may receive many onNext callbacks.

If an exception is thrown by an implementation the caller is expected to terminate the stream by calling StreamObserver.onError(Throwable) with the caught exception prior to propagating it.

Specified by:

onNext in interface StreamObserver<ServerReflectionRequest>

Parameters:

request - the value passed to the stream

handleReflectionRequest

private void handleReflectionRequest()

onCompleted

public void onCompleted()

Description copied from interface: StreamObserver

Receives a notification of successful stream completion.

May only be called once and if called it must be the last method called. In particular if an exception is thrown by an implementation of onCompleted no further calls to any method are allowed.

Specified by:

onCompleted in interface StreamObserver<ServerReflectionRequest>

onError

public void onError(Throwable cause)

Description copied from interface: StreamObserver

Receives a terminating error from the stream.

May only be called once and if called it must be the last method called. In particular if an exception is thrown by an implementation of onError no further calls to any method are allowed.

t should be a StatusException or StatusRuntimeException, but other Throwable types are possible. Callers should generally convert from a Status via Status.asException() or Status.asRuntimeException(). Implementations should generally convert to a Status via Status.fromThrowable(Throwable).

Specified by:

onError in interface StreamObserver<ServerReflectionRequest>

Parameters:

cause - the error occurred on the stream

getFileByName

private void getFileByName(ServerReflectionRequest request)

getFileContainingSymbol

private void getFileContainingSymbol(ServerReflectionRequest request)

getFileByExtension

private void getFileByExtension(ServerReflectionRequest request)

getAllExtensions

private void getAllExtensions(ServerReflectionRequest request)

listServices

private void listServices(ServerReflectionRequest request)

sendErrorResponse

private void sendErrorResponse(ServerReflectionRequest request,
 Status.Code code,
 String message)

createServerReflectionResponse

private ServerReflectionResponse createServerReflectionResponse(ServerReflectionRequest request,
 com.google.protobuf.Descriptors.FileDescriptor fd)