/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(
|