public abstract class AbstractTransportTest extends Object
ClientTransports and ServerTransports.| Modifier and Type | Field and Description |
|---|---|
org.junit.rules.ExpectedException |
thrown |
| Constructor and Description |
|---|
AbstractTransportTest() |
| Modifier and Type | Method and Description |
|---|---|
void |
basicStream() |
void |
clientCancel() |
void |
clientCancelFromWithinMessageRead() |
void |
clientStartAndStopOnceConnected() |
void |
clientStartStop() |
void |
earlyServerClose_noServerHeaders() |
void |
earlyServerClose_serverFailure() |
void |
earlyServerClose_withServerHeaders() |
void |
flowControlPushBack() |
void |
frameAfterRstStreamShouldNotBreakClientChannel()
Test for issue https://github.com/grpc/grpc-java/issues/1682
|
protected abstract io.grpc.internal.ManagedClientTransport |
newClientTransport(io.grpc.internal.InternalServer server)
Returns a new transport that when started will be able to connect to
server. |
protected abstract io.grpc.internal.InternalServer |
newServer()
Returns a new server that when started will be able to be connected to from the client.
|
protected abstract io.grpc.internal.InternalServer |
newServer(io.grpc.internal.InternalServer server)
Builds a new server that is listening on the same location as the given server instance does.
|
void |
newStream_afterTermination() |
void |
newStream_duringShutdown() |
void |
openStreamPreventsTermination() |
void |
ping_afterTermination() |
void |
ping_duringShutdown() |
void |
ping() |
void |
serverAlreadyListening() |
void |
serverCancel() |
void |
serverNotListening() |
void |
setUp() |
void |
shutdownNowKillsClientStream() |
void |
shutdownNowKillsServerStream() |
void |
tearDown() |
void |
transportInUse_clientCancel() |
void |
transportInUse_normalClose() |
void |
zeroMessageStream() |
protected abstract io.grpc.internal.InternalServer newServer()
protected abstract io.grpc.internal.InternalServer newServer(io.grpc.internal.InternalServer server)
protected abstract io.grpc.internal.ManagedClientTransport newClientTransport(io.grpc.internal.InternalServer server)
server.public void setUp()
public void tearDown()
throws InterruptedException
InterruptedExceptionpublic void frameAfterRstStreamShouldNotBreakClientChannel()
throws Exception
Exceptionpublic void clientStartAndStopOnceConnected()
throws Exception
Exceptionpublic void openStreamPreventsTermination()
throws Exception
Exceptionpublic void shutdownNowKillsClientStream()
throws Exception
Exceptionpublic void shutdownNowKillsServerStream()
throws Exception
Exceptionpublic void newStream_afterTermination()
throws Exception
Exceptionpublic void transportInUse_normalClose()
throws Exception
Exceptionpublic void transportInUse_clientCancel()
throws Exception
Exceptionpublic void earlyServerClose_withServerHeaders()
throws Exception
Exceptionpublic void earlyServerClose_noServerHeaders()
throws Exception
Exceptionpublic void earlyServerClose_serverFailure()
throws Exception
Exceptionpublic void clientCancelFromWithinMessageRead()
throws Exception
Exception