| /external/grpc-grpc-java/protobuf/src/test/java/io/grpc/protobuf/ |
| ProtoUtilsTest.java | 23 import io.grpc.MethodDescriptor.Marshaller;
37 Marshaller<Type> marshaller = ProtoUtils.marshaller(Type.getDefaultInstance()); local
38 InputStream is = marshaller.stream(proto);
40 assertEquals(proto, marshaller.parse(is));
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| GrpcUtilTest.java | 81 GrpcUtil.TimeoutMarshaller marshaller = local
84 assertEquals("0n", marshaller.toAsciiString(0L));
85 assertEquals(0L, (long) marshaller.parseAsciiString("0n"));
87 assertEquals("99999999n", marshaller.toAsciiString(99999999L));
88 assertEquals(99999999L, (long) marshaller.parseAsciiString("99999999n"));
91 assertEquals("100000u", marshaller.toAsciiString(100000000L));
92 assertEquals(100000000L, (long) marshaller.parseAsciiString("100000u"));
94 assertEquals("99999999u", marshaller.toAsciiString(99999999999L));
95 assertEquals(99999999000L, (long) marshaller.parseAsciiString("99999999u"));
98 assertEquals("100000m", marshaller.toAsciiString(100000000000L))
[all...] |
| /external/grpc-grpc-java/protobuf-lite/src/test/java/io/grpc/protobuf/lite/ |
| ProtoLiteUtilsTest.java | 34 import io.grpc.MethodDescriptor.Marshaller;
56 private Marshaller<Type> marshaller = ProtoLiteUtils.marshaller(Type.getDefaultInstance()); field in class:ProtoLiteUtilsTest
61 assertSame(proto, marshaller.parse(marshaller.stream(proto)));
66 InputStream is = marshaller.stream(proto);
68 assertEquals(proto, marshaller.parse(is));
73 InputStream is = marshaller.stream(proto);
83 assertEquals(Type.getDefaultInstance(), marshaller.parse(is))
139 Marshaller<Empty> marshaller = ProtoLiteUtils.marshaller(Empty.getDefaultInstance()); local
222 Marshaller<Type> marshaller = ProtoLiteUtils.marshaller(Type.getDefaultInstance()); local
[all...] |
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| InternalMetadata.java | 32 * A specialized plain ASCII marshaller. Both input and output are assumed to be valid header
47 public static <T> Key<T> keyOf(String name, TrustedAsciiMarshaller<T> marshaller) {
49 return Metadata.Key.of(name, isPseudo, marshaller);
53 public static <T> Key<T> keyOf(String name, AsciiMarshaller<T> marshaller) {
55 return Metadata.Key.of(name, isPseudo, marshaller);
|
| Metadata.java | 62 * Simple metadata marshaller that encodes bytes as is.
87 * Simple metadata marshaller that encodes strings as is.
482 /** Marshaller for metadata values that are serialized into raw binary. */
502 * Marshaller for metadata values that are serialized into ASCII strings. The strings contain only
559 * its marshaller, and the marshaller can be mutable though not recommended.
577 public static <T> Key<T> of(String name, BinaryMarshaller<T> marshaller) {
578 return new BinaryKey<T>(name, marshaller);
587 public static <T> Key<T> of(String name, AsciiMarshaller<T> marshaller) {
588 return of(name, false, marshaller);
710 private final BinaryMarshaller<T> marshaller; field in class:BinaryKey
736 private final AsciiMarshaller<T> marshaller; field in class:AsciiKey
761 private final TrustedAsciiMarshaller<T> marshaller; field in class:TrustedAsciiKey
[all...] |
| ServerInterceptors.java | 140 final MethodDescriptor.Marshaller<InputStream> marshaller = local
141 new MethodDescriptor.Marshaller<InputStream>() {
157 return useMarshalledMessages(serviceDef, marshaller);
176 final MethodDescriptor.Marshaller<T> marshaller) {
185 originalMethodDescriptor.toBuilder(marshaller, marshaller).build();
|
| /external/grpc-grpc-java/protobuf-nano/src/test/java/io/grpc/protobuf/nano/ |
| NanoUtilsTest.java | 27 import io.grpc.MethodDescriptor.Marshaller;
41 private Marshaller<Message> marshaller = NanoUtils.marshaller(new MessageNanoFactory<Message>() { field in class:NanoUtilsTest
54 Message m2 = marshaller.parse(marshaller.stream(m));
66 marshaller.parse(is);
79 Message m2 = marshaller.parse(marshaller.stream(m));
94 InputStream is = marshaller.stream(m)
[all...] |
| /external/grpc-grpc-java/protobuf/src/main/java/io/grpc/protobuf/ |
| ProtoUtils.java | 22 import io.grpc.MethodDescriptor.Marshaller;
31 * Create a {@link Marshaller} for protos of the same type as {@code defaultInstance}.
35 public static <T extends Message> Marshaller<T> marshaller(final T defaultInstance) { method in class:ProtoUtils
36 return ProtoLiteUtils.marshaller(defaultInstance);
51 * Produce a metadata marshaller for a protobuf type.
|
| /external/grpc-grpc-java/netty/src/jmh/java/io/grpc/netty/ |
| MethodDescriptorBenchmark.java | 39 private static final MethodDescriptor.Marshaller<Void> marshaller = field in class:MethodDescriptorBenchmark
40 new MethodDescriptor.Marshaller<Void>() {
55 .setRequestMarshaller(marshaller)
56 .setResponseMarshaller(marshaller)
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| MockServiceHelper.cs | 55 public MockServiceHelper(string host = null, Marshaller<string> marshaller = null, IEnumerable<ChannelOption> channelOptions = null)
59 marshaller = marshaller ?? Marshallers.StringMarshaller;
65 marshaller,
66 marshaller);
72 marshaller,
73 marshaller);
79 marshaller,
80 marshaller);
[all...] |
| MarshallingErrorsTest.cs | 45 var marshaller = new Marshaller<string>(
65 helper = new MockServiceHelper(Host, marshaller);
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| LoadServer.java | 25 import io.grpc.MethodDescriptor.Marshaller;
58 private static final Marshaller<ByteBuf> marshaller = new ByteBufOutputMarshaller(); field in class:LoadServer
63 BenchmarkServiceGrpc.getUnaryCallMethod().toBuilder(marshaller, marshaller)
70 BenchmarkServiceGrpc.getStreamingCallMethod().toBuilder(marshaller, marshaller)
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| Marshaller.cs | 27 public class Marshaller<T>
33 /// Initializes a new marshaller.
37 public Marshaller(Func<T, byte[]> serializer, Func<byte[], T> deserializer)
72 /// Creates a marshaller from specified serializer and deserializer.
74 public static Marshaller<T> Create<T>(Func<T, byte[]> serializer, Func<byte[], T> deserializer)
76 return new Marshaller<T>(serializer, deserializer);
80 /// Returns a marshaller for <c>string</c> type. This is useful for testing.
82 public static Marshaller<string> StringMarshaller
86 return new Marshaller<string>(System.Text.Encoding.UTF8.GetBytes,
|
| CallInvocationDetails.cs | 35 readonly Marshaller<TRequest> requestMarshaller;
36 readonly Marshaller<TResponse> responseMarshaller;
68 /// <param name="requestMarshaller">Request marshaller.</param>
69 /// <param name="responseMarshaller">Response marshaller.</param>
71 public CallInvocationDetails(Channel channel, string method, string host, Marshaller<TRequest> requestMarshaller, Marshaller<TResponse> responseMarshaller, CallOptions options)
115 /// Gets marshaller used to serialize requests.
117 public Marshaller<TRequest> RequestMarshaller
126 /// Gets marshaller used to deserialized responses.
128 public Marshaller<TResponse> ResponseMarshalle
[all...] |
| Method.cs | 79 readonly Marshaller<TRequest> requestMarshaller;
80 readonly Marshaller<TResponse> responseMarshaller;
89 /// <param name="requestMarshaller">Marshaller used for request messages.</param>
90 /// <param name="responseMarshaller">Marshaller used for response messages.</param>
91 public Method(MethodType type, string serviceName, string name, Marshaller<TRequest> requestMarshaller, Marshaller<TResponse> responseMarshaller)
135 /// Gets the marshaller used for request messages.
137 public Marshaller<TRequest> RequestMarshaller
146 /// Gets the marshaller used for response messages.
148 public Marshaller<TResponse> ResponseMarshalle
[all...] |
| /external/grpc-grpc-java/protobuf/ |
| grpc-protobuf-1.14.0.jar | |
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| OkHttpClientStreamTest.java | 60 @Mock private MethodDescriptor.Marshaller<Void> marshaller; field in class:OkHttpClientStreamTest
78 .setRequestMarshaller(marshaller)
79 .setResponseMarshaller(marshaller)
190 .setRequestMarshaller(marshaller)
191 .setResponseMarshaller(marshaller)
|
| /external/flatbuffers/tests/MyGame/Example/ |
| MonsterStorageGrpc.java | 86 .setRequestMarshaller(FlatbuffersUtils.marshaller(
88 .setResponseMarshaller(FlatbuffersUtils.marshaller(
119 .setRequestMarshaller(FlatbuffersUtils.marshaller(
121 .setResponseMarshaller(FlatbuffersUtils.marshaller(
152 .setRequestMarshaller(FlatbuffersUtils.marshaller(
154 .setResponseMarshaller(FlatbuffersUtils.marshaller(
185 .setRequestMarshaller(FlatbuffersUtils.marshaller(
187 .setResponseMarshaller(FlatbuffersUtils.marshaller(
|
| /external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ |
| TestServiceGrpc.java | 54 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
56 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
86 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
88 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
118 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
120 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
150 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
152 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
182 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
184 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
[all...] |
| /external/grpc-grpc-java/protobuf-nano/src/main/java/io/grpc/protobuf/nano/ |
| NanoUtils.java | 23 import io.grpc.MethodDescriptor.Marshaller;
38 * Adapt {@code parser} to a {@link Marshaller}.
42 public static <T extends MessageNano> Marshaller<T> marshaller(MessageNanoFactory<T> factory) { method in class:NanoUtils
46 private static final class MessageMarshaller<T extends MessageNano> implements Marshaller<T> {
|
| /external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/ |
| ChannelzGrpc.java | 54 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
56 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
86 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
88 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
118 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
120 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
150 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
152 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
182 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
184 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
[all...] |
| /external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ |
| BenchmarkServiceGrpc.java | 50 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
52 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
82 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
84 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
114 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
116 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
146 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
148 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
178 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
180 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
[all...] |
| WorkerServiceGrpc.java | 50 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
52 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
82 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
84 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
114 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
116 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
146 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
148 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
| /external/flatbuffers/grpc/flatbuffers-java-grpc/src/main/java/com/google/flatbuffers/grpc/ |
| FlatbuffersUtils.java | 95 public static <T extends Table> MethodDescriptor.Marshaller<T> marshaller(final Class<T> clazz, final FBExtactor<T> extractor) { method in class:FlatbuffersUtils
|
| /external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/ |
| SimpleServiceGrpc.java | 53 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
55 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
85 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
87 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
117 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
119 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
149 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
151 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
