commit	f83145865ab7039bb7c860bef6916ec28d0da790	[log] [tgz]
author	nmittler <nathanmittler@google.com>	Tue Jan 27 10:25:39 2015 -0800
committer	nmittler <nathanmittler@google.com>	Tue Jan 27 11:25:25 2015 -0800
tree	1791b54aa1d3d920e8d162d2afc5e8cc87abe665
parent	aeeebb7cdbdefadcf4e200974e8ef504fae05756 [diff]

Removing all references to "stubby"

README.md[diff]
all/build.gradle[diff]
auth/build.gradle[diff]
auth/src/main/java/io/grpc/auth/OAuth2AccessTokenProvider.java[Renamed from auth/src/main/java/com/google/net/stubby/auth/OAuth2AccessTokenProvider.java - diff]
auth/src/main/java/io/grpc/auth/OAuth2ChannelInterceptor.java[Renamed from auth/src/main/java/com/google/net/stubby/auth/OAuth2ChannelInterceptor.java - diff]
build.gradle[diff]
compiler/run_test.sh[diff]
compiler/src/java_generator.cc[diff]
compiler/test/TestService.java.txt[diff]
compiler/test/test.proto[diff]
core/build.gradle[diff]
core/src/main/java/io/grpc/AbstractChannelBuilder.java[Renamed from core/src/main/java/com/google/net/stubby/AbstractChannelBuilder.java - diff]
core/src/main/java/io/grpc/AbstractServerBuilder.java[Renamed from core/src/main/java/com/google/net/stubby/AbstractServerBuilder.java - diff]
core/src/main/java/io/grpc/Call.java[Renamed from core/src/main/java/com/google/net/stubby/Call.java - diff]
core/src/main/java/io/grpc/Channel.java[Renamed from core/src/main/java/com/google/net/stubby/Channel.java - diff]
core/src/main/java/io/grpc/ChannelImpl.java[Renamed from core/src/main/java/com/google/net/stubby/ChannelImpl.java - diff]
core/src/main/java/io/grpc/ClientInterceptor.java[Renamed from core/src/main/java/com/google/net/stubby/ClientInterceptor.java - diff]
core/src/main/java/io/grpc/ClientInterceptors.java[Renamed from core/src/main/java/com/google/net/stubby/ClientInterceptors.java - diff]
core/src/main/java/io/grpc/DeferredInputStream.java[Renamed from core/src/main/java/com/google/net/stubby/DeferredInputStream.java - diff]
core/src/main/java/io/grpc/GrpcFramingUtil.java[Renamed from core/src/main/java/com/google/net/stubby/GrpcFramingUtil.java - diff]
core/src/main/java/io/grpc/HandlerRegistry.java[Renamed from core/src/main/java/com/google/net/stubby/HandlerRegistry.java - diff]
core/src/main/java/io/grpc/Marshaller.java[Renamed from core/src/main/java/com/google/net/stubby/Marshaller.java - diff]
core/src/main/java/io/grpc/Metadata.java[Renamed from core/src/main/java/com/google/net/stubby/Metadata.java - diff]
core/src/main/java/io/grpc/MethodDescriptor.java[Renamed from core/src/main/java/com/google/net/stubby/MethodDescriptor.java - diff]
core/src/main/java/io/grpc/MethodType.java[Renamed from core/src/main/java/com/google/net/stubby/MethodType.java - diff]
core/src/main/java/io/grpc/MutableHandlerRegistry.java[Renamed from core/src/main/java/com/google/net/stubby/MutableHandlerRegistry.java - diff]
core/src/main/java/io/grpc/MutableHandlerRegistryImpl.java[Renamed from core/src/main/java/com/google/net/stubby/MutableHandlerRegistryImpl.java - diff]
core/src/main/java/io/grpc/SerializingExecutor.java[Renamed from core/src/main/java/com/google/net/stubby/SerializingExecutor.java - diff]
core/src/main/java/io/grpc/Server.java[Renamed from core/src/main/java/com/google/net/stubby/Server.java - diff]
core/src/main/java/io/grpc/ServerCall.java[Renamed from core/src/main/java/com/google/net/stubby/ServerCall.java - diff]
core/src/main/java/io/grpc/ServerCallHandler.java[Renamed from core/src/main/java/com/google/net/stubby/ServerCallHandler.java - diff]
core/src/main/java/io/grpc/ServerImpl.java[Renamed from core/src/main/java/com/google/net/stubby/ServerImpl.java - diff]
core/src/main/java/io/grpc/ServerInterceptor.java[Renamed from core/src/main/java/com/google/net/stubby/ServerInterceptor.java - diff]
core/src/main/java/io/grpc/ServerInterceptors.java[Renamed from core/src/main/java/com/google/net/stubby/ServerInterceptors.java - diff]
core/src/main/java/io/grpc/ServerMethodDefinition.java[Renamed from core/src/main/java/com/google/net/stubby/ServerMethodDefinition.java - diff]
core/src/main/java/io/grpc/ServerServiceDefinition.java[Renamed from core/src/main/java/com/google/net/stubby/ServerServiceDefinition.java - diff]
core/src/main/java/io/grpc/SharedResourceHolder.java[Renamed from core/src/main/java/com/google/net/stubby/SharedResourceHolder.java - diff]
core/src/main/java/io/grpc/Status.java[Renamed from core/src/main/java/com/google/net/stubby/Status.java - diff]
core/src/main/java/io/grpc/proto/DeferredProtoInputStream.java[Renamed from core/src/main/java/com/google/net/stubby/proto/DeferredProtoInputStream.java - diff]
core/src/main/java/io/grpc/proto/ProtoUtils.java[Renamed from core/src/main/java/com/google/net/stubby/proto/ProtoUtils.java - diff]
core/src/main/java/io/grpc/transport/AbstractBuffer.java[Renamed from core/src/main/java/com/google/net/stubby/transport/AbstractBuffer.java - diff]
core/src/main/java/io/grpc/transport/AbstractClientStream.java[Renamed from core/src/main/java/com/google/net/stubby/transport/AbstractClientStream.java - diff]
core/src/main/java/io/grpc/transport/AbstractClientTransport.java[Renamed from core/src/main/java/com/google/net/stubby/transport/AbstractClientTransport.java - diff]
core/src/main/java/io/grpc/transport/AbstractServerStream.java[Renamed from core/src/main/java/com/google/net/stubby/transport/AbstractServerStream.java - diff]
core/src/main/java/io/grpc/transport/AbstractStream.java[Renamed from core/src/main/java/com/google/net/stubby/transport/AbstractStream.java - diff]
core/src/main/java/io/grpc/transport/Buffer.java[Renamed from core/src/main/java/com/google/net/stubby/transport/Buffer.java - diff]
core/src/main/java/io/grpc/transport/Buffers.java[Renamed from core/src/main/java/com/google/net/stubby/transport/Buffers.java - diff]
core/src/main/java/io/grpc/transport/ClientStream.java[Renamed from core/src/main/java/com/google/net/stubby/transport/ClientStream.java - diff]
core/src/main/java/io/grpc/transport/ClientStreamListener.java[Renamed from core/src/main/java/com/google/net/stubby/transport/ClientStreamListener.java - diff]
core/src/main/java/io/grpc/transport/ClientTransport.java[Renamed from core/src/main/java/com/google/net/stubby/transport/ClientTransport.java - diff]
core/src/main/java/io/grpc/transport/ClientTransportFactory.java[Renamed from core/src/main/java/com/google/net/stubby/transport/ClientTransportFactory.java - diff]
core/src/main/java/io/grpc/transport/CompositeBuffer.java[Renamed from core/src/main/java/com/google/net/stubby/transport/CompositeBuffer.java - diff]
core/src/main/java/io/grpc/transport/ForwardingBuffer.java[Renamed from core/src/main/java/com/google/net/stubby/transport/ForwardingBuffer.java - diff]
core/src/main/java/io/grpc/transport/Http2ClientStream.java[Renamed from core/src/main/java/com/google/net/stubby/transport/Http2ClientStream.java - diff]
core/src/main/java/io/grpc/transport/HttpUtil.java[Renamed from core/src/main/java/com/google/net/stubby/transport/HttpUtil.java - diff]
core/src/main/java/io/grpc/transport/MessageDeframer.java[Renamed from core/src/main/java/com/google/net/stubby/transport/MessageDeframer.java - diff]
core/src/main/java/io/grpc/transport/MessageFramer.java[Renamed from core/src/main/java/com/google/net/stubby/transport/MessageFramer.java - diff]
core/src/main/java/io/grpc/transport/ServerListener.java[Renamed from core/src/main/java/com/google/net/stubby/transport/ServerListener.java - diff]
core/src/main/java/io/grpc/transport/ServerStream.java[Renamed from core/src/main/java/com/google/net/stubby/transport/ServerStream.java - diff]
core/src/main/java/io/grpc/transport/ServerStreamListener.java[Renamed from core/src/main/java/com/google/net/stubby/transport/ServerStreamListener.java - diff]
core/src/main/java/io/grpc/transport/ServerTransportListener.java[Renamed from core/src/main/java/com/google/net/stubby/transport/ServerTransportListener.java - diff]
core/src/main/java/io/grpc/transport/Stream.java[Renamed from core/src/main/java/com/google/net/stubby/transport/Stream.java - diff]
core/src/main/java/io/grpc/transport/StreamListener.java[Renamed from core/src/main/java/com/google/net/stubby/transport/StreamListener.java - diff]
core/src/main/java/io/grpc/transport/TransportFrameUtil.java[Renamed from core/src/main/java/com/google/net/stubby/transport/TransportFrameUtil.java - diff]
core/src/test/java/io/grpc/ClientInterceptorsTest.java[Renamed from core/src/test/java/com/google/net/stubby/ClientInterceptorsTest.java - diff]
core/src/test/java/io/grpc/MetadataTest.java[Renamed from core/src/test/java/com/google/net/stubby/MetadataTest.java - diff]
core/src/test/java/io/grpc/MutableHandlerRegistryImplTest.java[Renamed from core/src/test/java/com/google/net/stubby/MutableHandlerRegistryImplTest.java - diff]
core/src/test/java/io/grpc/ServerImplTest.java[Renamed from core/src/test/java/com/google/net/stubby/ServerImplTest.java - diff]
core/src/test/java/io/grpc/ServerInterceptorsTest.java[Renamed from core/src/test/java/com/google/net/stubby/ServerInterceptorsTest.java - diff]
core/src/test/java/io/grpc/SharedResourceHolderTest.java[Renamed from core/src/test/java/com/google/net/stubby/SharedResourceHolderTest.java - diff]
core/src/test/java/io/grpc/transport/AbstractBufferTest.java[Renamed from core/src/test/java/com/google/net/stubby/transport/AbstractBufferTest.java - diff]
core/src/test/java/io/grpc/transport/BufferTestBase.java[Renamed from core/src/test/java/com/google/net/stubby/transport/BufferTestBase.java - diff]
core/src/test/java/io/grpc/transport/BuffersArrayTest.java[Renamed from core/src/test/java/com/google/net/stubby/transport/BuffersArrayTest.java - diff]
core/src/test/java/io/grpc/transport/BuffersByteBufferTest.java[Renamed from core/src/test/java/com/google/net/stubby/transport/BuffersByteBufferTest.java - diff]
core/src/test/java/io/grpc/transport/CompositeBufferTest.java[Renamed from core/src/test/java/com/google/net/stubby/transport/CompositeBufferTest.java - diff]
core/src/test/java/io/grpc/transport/MessageDeframerTest.java[Renamed from core/src/test/java/com/google/net/stubby/transport/MessageDeframerTest.java - diff]
core/src/test/java/io/grpc/transport/MessageFramerTest.java[Renamed from core/src/test/java/com/google/net/stubby/transport/MessageFramerTest.java - diff]
core/src/test/java/io/grpc/transport/TransportFrameUtilTest.java[Renamed from core/src/test/java/com/google/net/stubby/transport/TransportFrameUtilTest.java - diff]
examples/src/main/java/io/grpc/examples/MathClient.java[Renamed from examples/src/main/java/com/google/net/stubby/examples/MathClient.java - diff]
examples/src/main/java/io/grpc/examples/MathServer.java[Renamed from examples/src/main/java/com/google/net/stubby/examples/MathServer.java - diff]
examples/src/main/java/io/grpc/examples/StockClient.java[Renamed from examples/src/main/java/com/google/net/stubby/examples/StockClient.java - diff]
examples/src/main/java/io/grpc/examples/StockServer.java[Renamed from examples/src/main/java/com/google/net/stubby/examples/StockServer.java - diff]
examples/src/main/proto/math.proto[diff]
examples/src/main/proto/stock.proto[diff]
integration-testing/build.gradle[diff]
integration-testing/src/main/java/com/google/net/stubby/testing/integration/TestServiceGrpc.java[Deleted - diff]
integration-testing/src/main/java/io/grpc/testing/integration/AbstractTransportTest.java[Renamed from integration-testing/src/main/java/com/google/net/stubby/testing/integration/AbstractTransportTest.java - diff]
integration-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java[Renamed from integration-testing/src/main/java/com/google/net/stubby/testing/integration/TestServiceClient.java - diff]
integration-testing/src/main/java/io/grpc/testing/integration/TestServiceGrpc.java[Added - diff]
integration-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java[Renamed from integration-testing/src/main/java/com/google/net/stubby/testing/integration/TestServiceImpl.java - diff]
integration-testing/src/main/java/io/grpc/testing/integration/TestServiceServer.java[Renamed from integration-testing/src/main/java/com/google/net/stubby/testing/integration/TestServiceServer.java - diff]
integration-testing/src/main/java/io/grpc/testing/integration/Util.java[Renamed from integration-testing/src/main/java/com/google/net/stubby/testing/integration/Util.java - diff]
integration-testing/src/main/proto/io/grpc/testing/integration/empty.proto[Renamed from integration-testing/src/main/proto/stubby/testing/integration/empty.proto - diff]
integration-testing/src/main/proto/io/grpc/testing/integration/message_set.proto[Renamed from integration-testing/src/main/proto/stubby/testing/integration/message_set.proto - diff]
integration-testing/src/main/proto/io/grpc/testing/integration/messages.proto[Renamed from integration-testing/src/main/proto/stubby/testing/integration/messages.proto - diff]
integration-testing/src/main/resources/io/grpc/testing/integration/testdata/uncompressable.bin[Renamed from integration-testing/src/main/resources/com/google/net/stubby/testing/integration/testdata/uncompressable.bin - diff]
integration-testing/src/test/java/io/grpc/stub/StubConfigTest.java[Renamed from integration-testing/src/test/java/com/google/net/stubby/stub/StubConfigTest.java - diff]
integration-testing/src/test/java/io/grpc/testing/integration/Http2NettyTest.java[Renamed from integration-testing/src/test/java/com/google/net/stubby/testing/integration/Http2NettyTest.java - diff]
integration-testing/src/test/java/io/grpc/testing/integration/Http2OkHttpTest.java[Renamed from integration-testing/src/test/java/com/google/net/stubby/testing/integration/Http2OkHttpTest.java - diff]
netty/build.gradle[diff]
netty/src/main/java/io/grpc/transport/netty/CancelStreamCommand.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/CancelStreamCommand.java - diff]
netty/src/main/java/io/grpc/transport/netty/CreateStreamCommand.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/CreateStreamCommand.java - diff]
netty/src/main/java/io/grpc/transport/netty/Http2Negotiator.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/Http2Negotiator.java - diff]
netty/src/main/java/io/grpc/transport/netty/NegotiationType.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NegotiationType.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyBuffer.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyBuffer.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyChannelBuilder.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyChannelBuilder.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyClientHandler.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyClientHandler.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyClientStream.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyClientStream.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyClientTransport.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyClientTransport.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyClientTransportFactory.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyClientTransportFactory.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyServer.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyServer.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyServerBuilder.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyServerBuilder.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyServerHandler.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyServerHandler.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyServerStream.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyServerStream.java - diff]
netty/src/main/java/io/grpc/transport/netty/NettyServerTransport.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/NettyServerTransport.java - diff]
netty/src/main/java/io/grpc/transport/netty/SendGrpcFrameCommand.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/SendGrpcFrameCommand.java - diff]
netty/src/main/java/io/grpc/transport/netty/SendResponseHeadersCommand.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/SendResponseHeadersCommand.java - diff]
netty/src/main/java/io/grpc/transport/netty/Utils.java[Renamed from netty/src/main/java/com/google/net/stubby/transport/netty/Utils.java - diff]
netty/src/test/java/io/grpc/transport/netty/NettyBufferTest.java[Renamed from netty/src/test/java/com/google/net/stubby/transport/netty/NettyBufferTest.java - diff]
netty/src/test/java/io/grpc/transport/netty/NettyClientHandlerTest.java[Renamed from netty/src/test/java/com/google/net/stubby/transport/netty/NettyClientHandlerTest.java - diff]
netty/src/test/java/io/grpc/transport/netty/NettyClientStreamTest.java[Renamed from netty/src/test/java/com/google/net/stubby/transport/netty/NettyClientStreamTest.java - diff]
netty/src/test/java/io/grpc/transport/netty/NettyHandlerTestBase.java[Renamed from netty/src/test/java/com/google/net/stubby/transport/netty/NettyHandlerTestBase.java - diff]
netty/src/test/java/io/grpc/transport/netty/NettyServerHandlerTest.java[Renamed from netty/src/test/java/com/google/net/stubby/transport/netty/NettyServerHandlerTest.java - diff]
netty/src/test/java/io/grpc/transport/netty/NettyServerStreamTest.java[Renamed from netty/src/test/java/com/google/net/stubby/transport/netty/NettyServerStreamTest.java - diff]
netty/src/test/java/io/grpc/transport/netty/NettyStreamTestBase.java[Renamed from netty/src/test/java/com/google/net/stubby/transport/netty/NettyStreamTestBase.java - diff]
netty/src/test/java/io/grpc/transport/netty/NettyTestUtil.java[Renamed from netty/src/test/java/com/google/net/stubby/transport/netty/NettyTestUtil.java - diff]
okhttp/build.gradle[diff]
okhttp/src/main/java/io/grpc/transport/okhttp/AsyncFrameWriter.java[Renamed from okhttp/src/main/java/com/google/net/stubby/transport/okhttp/AsyncFrameWriter.java - diff]
okhttp/src/main/java/io/grpc/transport/okhttp/Headers.java[Renamed from okhttp/src/main/java/com/google/net/stubby/transport/okhttp/Headers.java - diff]
okhttp/src/main/java/io/grpc/transport/okhttp/OkHttpBuffer.java[Renamed from okhttp/src/main/java/com/google/net/stubby/transport/okhttp/OkHttpBuffer.java - diff]
okhttp/src/main/java/io/grpc/transport/okhttp/OkHttpChannelBuilder.java[Renamed from okhttp/src/main/java/com/google/net/stubby/transport/okhttp/OkHttpChannelBuilder.java - diff]
okhttp/src/main/java/io/grpc/transport/okhttp/OkHttpClientStream.java[Renamed from okhttp/src/main/java/com/google/net/stubby/transport/okhttp/OkHttpClientStream.java - diff]
okhttp/src/main/java/io/grpc/transport/okhttp/OkHttpClientTransport.java[Renamed from okhttp/src/main/java/com/google/net/stubby/transport/okhttp/OkHttpClientTransport.java - diff]
okhttp/src/main/java/io/grpc/transport/okhttp/OkHttpClientTransportFactory.java[Renamed from okhttp/src/main/java/com/google/net/stubby/transport/okhttp/OkHttpClientTransportFactory.java - diff]
okhttp/src/main/java/io/grpc/transport/okhttp/OutboundFlowController.java[Renamed from okhttp/src/main/java/com/google/net/stubby/transport/okhttp/OutboundFlowController.java - diff]
okhttp/src/main/java/io/grpc/transport/okhttp/Utils.java[Renamed from okhttp/src/main/java/com/google/net/stubby/transport/okhttp/Utils.java - diff]
okhttp/src/test/java/io/grpc/transport/okhttp/OkHttpClientTransportTest.java[Renamed from okhttp/src/test/java/com/google/net/stubby/transport/okhttp/OkHttpClientTransportTest.java - diff]
run-test-client.sh[diff]
run-test-server.sh[diff]
settings.gradle[diff]
stub/build.gradle[diff]
stub/src/main/java/io/grpc/stub/AbstractServiceDescriptor.java[Renamed from stub/src/main/java/com/google/net/stubby/stub/AbstractServiceDescriptor.java - diff]
stub/src/main/java/io/grpc/stub/AbstractStub.java[Renamed from stub/src/main/java/com/google/net/stubby/stub/AbstractStub.java - diff]
stub/src/main/java/io/grpc/stub/Calls.java[Renamed from stub/src/main/java/com/google/net/stubby/stub/Calls.java - diff]
stub/src/main/java/io/grpc/stub/MetadataUtils.java[Renamed from stub/src/main/java/com/google/net/stubby/stub/MetadataUtils.java - diff]
stub/src/main/java/io/grpc/stub/Method.java[Renamed from stub/src/main/java/com/google/net/stubby/stub/Method.java - diff]
stub/src/main/java/io/grpc/stub/ServerCalls.java[Renamed from stub/src/main/java/com/google/net/stubby/stub/ServerCalls.java - diff]
stub/src/main/java/io/grpc/stub/StreamObserver.java[Renamed from stub/src/main/java/com/google/net/stubby/stub/StreamObserver.java - diff]
stub/src/main/java/io/grpc/stub/StreamRecorder.java[Renamed from stub/src/main/java/com/google/net/stubby/stub/StreamRecorder.java - diff]
testing/build.gradle[diff]
testing/src/main/java/io/grpc/testing/TestUtils.java[Renamed from testing/src/main/java/com/google/net/stubby/testing/TestUtils.java - diff]

151 files changed

tree: 1791b54aa1d3d920e8d162d2afc5e8cc87abe665

README.md

grpc-java

Heres a quick readers guide to the code to help folks get started. At a high level there are three distinct layers to the library: stub, channel & transport.

Stub

The 'stub' layer is what is exposed to most developers and provides type-safe bindings to whatever datamodel/IDL/interface you are adapting. An example is provided of a binding to code generated by the protocol-buffers compiler but others should be trivial to add and are welcome.

Key Interfaces

Stream Observer

Channel

The 'channel' layer is an abstraction over transport handling that is suitable for interception/decoration and exposes more behavior to the application than the stub layer. It is intended to be easy for application frameworks to use this layer to address cross-cutting concerns such as logging, monitoring, auth etc. Flow-control is also exposed at this layer to allow more sophisticated applications to interact with it directly.

Common

Client

Server

Transport

The 'transport' layer does the heavy lifting of putting & taking bytes off the wire. The interfaces to it are abstract just enough to allow plugging in of different implementations. Transports are modeled as 'Stream' factories. The variation in interface between a server stream and a client stream exists to codify their differing semantics for cancellation and error reporting.

Common

Client

Server

Examples

Tests showing how these layers are composed to execute calls using protobuf messages can be found here https://github.com/google/grpc-java/tree/master/integration-testing/src/main/java/io/grpc/testing/integration