A B C D E F G H I L M N O P R S T Z

A

AbstractClientTransportFactoryTest - Class in io.grpc.internal.testing

AbstractClientTransportFactoryTest() - Constructor for class io.grpc.internal.testing.AbstractClientTransportFactoryTest

AbstractTransportTest - Class in io.grpc.internal.testing

Standard unit tests for ClientTransports and ServerTransports.

AbstractTransportTest() - Constructor for class io.grpc.internal.testing.AbstractTransportTest

awaitCompletion() - Method in class io.grpc.testing.StreamRecorder

Waits for the stream to terminate.

awaitCompletion(int, TimeUnit) - Method in class io.grpc.testing.StreamRecorder

Waits a fixed timeout for the stream to terminate.

B

basicStream() - Method in class io.grpc.internal.testing.AbstractTransportTest

C

clientCancel() - Method in class io.grpc.internal.testing.AbstractTransportTest

clientCancelFromWithinMessageRead() - Method in class io.grpc.internal.testing.AbstractTransportTest

clientStartAndStopOnceConnected() - Method in class io.grpc.internal.testing.AbstractTransportTest

clientStartStop() - Method in class io.grpc.internal.testing.AbstractTransportTest

create() - Static method in class io.grpc.testing.StreamRecorder

Creates a new recorder.

D

deadline() - Static method in class io.grpc.testing.DeadlineSubject

DeadlineSubject - Class in io.grpc.testing

Propositions for Deadline subjects.

DeadlineSubject.TolerantDeadlineComparison - Class in io.grpc.testing

A partially specified proposition about an approximate relationship to a deadline subject using a tolerance.

E

earlyServerClose_noServerHeaders() - Method in class io.grpc.internal.testing.AbstractTransportTest

earlyServerClose_serverFailure() - Method in class io.grpc.internal.testing.AbstractTransportTest

earlyServerClose_withServerHeaders() - Method in class io.grpc.internal.testing.AbstractTransportTest

echoRequestHeadersInterceptor(Metadata.Key<?>...) - Static method in class io.grpc.testing.TestUtils

Echo the request headers from a client into response headers and trailers.

equals(Object) - Method in class io.grpc.testing.DeadlineSubject.TolerantDeadlineComparison

Deprecated.

Object.equals(Object) is not supported on TolerantDeadlineComparison If you meant to compare deadlines, use DeadlineSubject.TolerantDeadlineComparison.of(Deadline) instead.

F

firstValue() - Method in class io.grpc.testing.StreamRecorder

Returns a ListenableFuture for the first value received from the stream.

flowControlPushBack() - Method in class io.grpc.internal.testing.AbstractTransportTest

frameAfterRstStreamShouldNotBreakClientChannel() - Method in class io.grpc.internal.testing.AbstractTransportTest

Test for issue https://github.com/grpc/grpc-java/issues/1682

G

getError() - Method in class io.grpc.testing.StreamRecorder

Returns the stream terminating error.

getValues() - Method in class io.grpc.testing.StreamRecorder

Returns the current set of received values.

H

hashCode() - Method in class io.grpc.testing.DeadlineSubject.TolerantDeadlineComparison

Deprecated.

Object.hashCode() is not supported on TolerantDeadlineComparison

I

io.grpc.internal.testing - package io.grpc.internal.testing

io.grpc.testing - package io.grpc.testing

isWithin(long, TimeUnit) - Method in class io.grpc.testing.DeadlineSubject

Prepares for a check that the subject is deadline within the given tolerance of an expected value that will be provided in the next call in the fluent chain.

L

loadCert(String) - Static method in class io.grpc.testing.TestUtils

Saves a file from the classpath resources in src/main/resources/certs as a file on the filesystem.

loadX509Cert(String) - Static method in class io.grpc.testing.TestUtils

Loads an X.509 certificate from the classpath resources in src/main/resources/certs.

M

multipleCallsToCloseShouldNotThrow() - Method in class io.grpc.internal.testing.AbstractClientTransportFactoryTest

N

newClientTransport(InternalServer) - Method in class io.grpc.internal.testing.AbstractTransportTest

Returns a new transport that when started will be able to connect to server.

newClientTransportAfterCloseShouldThrow() - Method in class io.grpc.internal.testing.AbstractClientTransportFactoryTest

newClientTransportFactory() - Method in class io.grpc.internal.testing.AbstractClientTransportFactoryTest

newServer() - Method in class io.grpc.internal.testing.AbstractTransportTest

Returns a new server that when started will be able to be connected to from the client.

newServer(InternalServer) - Method in class io.grpc.internal.testing.AbstractTransportTest

Builds a new server that is listening on the same location as the given server instance does.

newSslSocketFactoryForCa(File) - Static method in class io.grpc.testing.TestUtils

Creates an SSLSocketFactory which contains certChainFile as its only root certificate.

newSslSocketFactoryForCa(InputStream) - Static method in class io.grpc.testing.TestUtils

Creates an SSLSocketFactory which contains certChainFile as its only root certificate.

newStream_afterTermination() - Method in class io.grpc.internal.testing.AbstractTransportTest

newStream_duringShutdown() - Method in class io.grpc.internal.testing.AbstractTransportTest

O

of(Deadline) - Method in class io.grpc.testing.DeadlineSubject.TolerantDeadlineComparison

Fails if the subject was expected to be within the tolerance of the given value but was not or if it was expected not to be within the tolerance but was.

onCompleted() - Method in class io.grpc.testing.StreamRecorder

onError(Throwable) - Method in class io.grpc.testing.StreamRecorder

onNext(T) - Method in class io.grpc.testing.StreamRecorder

openStreamPreventsTermination() - Method in class io.grpc.internal.testing.AbstractTransportTest

P

ping() - Method in class io.grpc.internal.testing.AbstractTransportTest

ping_afterTermination() - Method in class io.grpc.internal.testing.AbstractTransportTest

ping_duringShutdown() - Method in class io.grpc.internal.testing.AbstractTransportTest

preferredTestCiphers() - Static method in class io.grpc.testing.TestUtils

Returns the ciphers preferred to use during tests.

R

recordRequestHeadersInterceptor(AtomicReference<Metadata>) - Static method in class io.grpc.testing.TestUtils

Capture the request headers from a client.

recordServerCallInterceptor(AtomicReference<ServerCall<?, ?>>) - Static method in class io.grpc.testing.TestUtils

Capture the request attributes.

S

serverAlreadyListening() - Method in class io.grpc.internal.testing.AbstractTransportTest

serverCancel() - Method in class io.grpc.internal.testing.AbstractTransportTest

serverNotListening() - Method in class io.grpc.internal.testing.AbstractTransportTest

setUp() - Method in class io.grpc.internal.testing.AbstractTransportTest

shutdownNowKillsClientStream() - Method in class io.grpc.internal.testing.AbstractTransportTest

shutdownNowKillsServerStream() - Method in class io.grpc.internal.testing.AbstractTransportTest

StreamRecorder<T> - Class in io.grpc.testing

Utility implementation of StreamObserver used in testing.

T

tearDown() - Method in class io.grpc.internal.testing.AbstractTransportTest

TEST_SERVER_HOST - Static variable in class io.grpc.testing.TestUtils

testServerAddress(String, int) - Static method in class io.grpc.testing.TestUtils

Creates a new InetSocketAddress that overrides the host with TestUtils.TEST_SERVER_HOST.

testServerAddress(int) - Static method in class io.grpc.testing.TestUtils

Creates a new InetSocketAddress on localhost that overrides the host with TestUtils.TEST_SERVER_HOST.

TestUtils - Class in io.grpc.testing

Common utility functions useful for writing tests.

thrown - Variable in class io.grpc.internal.testing.AbstractTransportTest

transportInUse_clientCancel() - Method in class io.grpc.internal.testing.AbstractTransportTest

transportInUse_normalClose() - Method in class io.grpc.internal.testing.AbstractTransportTest

Z

zeroMessageStream() - Method in class io.grpc.internal.testing.AbstractTransportTest

A B C D E F G H I L M N O P R S T Z