| /external/archive-patcher/shared/src/main/java/com/google/archivepatcher/shared/ |
| ByteArrayInputStreamFactory.java | 33 public ByteArrayInputStream newStream() throws IOException {
|
| MultiViewInputStreamFactory.java | 33 public InputStream newStream() throws IOException;
|
| RandomAccessFileInputStreamFactory.java | 44 * @param file the file to use in {@link #newStream()}
45 * @param rangeOffset the range offset to use in {@link #newStream()}
46 * @param rangeLength the range length to use in {@link #newStream()}
55 public RandomAccessFileInputStream newStream() throws IOException {
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| ClientTransport.java | 52 ClientStream newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions);
|
| FailingClientTransport.java | 47 public ClientStream newStream(
|
| ForwardingConnectionClientTransport.java | 47 public ClientStream newStream(
49 return delegate().newStream(method, headers, callOptions);
|
| CallCredentialsApplyingTransportFactory.java | 75 public ClientStream newStream(
98 return delegate.newStream(method, headers, callOptions);
|
| DelayedClientTransport.java | 131 public final ClientStream newStream(
153 return transport.newStream(
270 * <p>This method may be called concurrently with {@code newStream()}, and it's safe. All pending
358 realStream = transport.newStream(
|
| InternalSubchannel.java | 688 public ClientStream newStream(
690 final ClientStream streamDelegate = super.newStream(method, headers, callOptions);
|
| /external/antlr/tool/src/test/java/org/antlr/test/ |
| TestBufferedTreeNodeStream.java | 43 public TreeNodeStream newStream(Object t) {
66 TreeNodeStream stream = newStream(r0);
|
| TestTreeNodeStream.java | 41 public TreeNodeStream newStream(Object t) {
52 TreeNodeStream stream = newStream(t);
69 TreeNodeStream stream = newStream(t);
92 TreeNodeStream stream = newStream(root);
109 TreeNodeStream stream = newStream(root);
124 TreeNodeStream stream = newStream(root);
138 TreeNodeStream stream = newStream(t);
155 TreeNodeStream stream = newStream(t);
183 TreeNodeStream stream = newStream(r0);
214 TreeNodeStream stream = newStream(r0)
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| CallCredentialsApplyingTest.java | 110 when(mockTransport.newStream(same(method), any(Metadata.class), any(CallOptions.class)))
126 transport.newStream(method, origHeaders, callOptions);
146 transport.newStream(method, origHeaders, callOptions);
167 transport.newStream(method, origHeaders,
187 (FailingClientStream) transport.newStream(method, origHeaders, callOptions);
189 verify(mockTransport, never()).newStream(method, origHeaders, callOptions);
209 ClientStream stream = transport.newStream(method, origHeaders, callOptions);
211 verify(mockTransport).newStream(method, origHeaders, callOptions);
232 (FailingClientStream) transport.newStream(method, origHeaders, callOptions);
234 verify(mockTransport, never()).newStream(method, origHeaders, callOptions)
[all...] |
| DelayedClientTransportTest.java | 111 when(mockRealTransport.newStream(same(method), same(headers), same(callOptions)))
113 when(mockRealTransport2.newStream(same(method2), same(headers2), same(callOptions2)))
124 ClientStream stream = delayedTransport.newStream(method, headers, callOptions);
134 verify(mockRealTransport).newStream(same(method), same(headers), same(callOptions));
143 ClientStream stream = delayedTransport.newStream(method, headers, callOptions);
152 verify(mockRealTransport).newStream(same(method), same(headers), same(callOptions));
170 ClientStream stream = delayedTransport.newStream(method, headers, callOptions);
173 verify(mockRealTransport, never()).newStream(
182 ClientStream stream = delayedTransport.newStream(method, headers, callOptions);
185 verify(mockRealTransport, never()).newStream(
[all...] |
| ClientCallImplTest.java | 132 when(transport.newStream(
287 verify(transport).newStream(eq(method), metadataCaptor.capture(), same(baseCallOptions));
328 verify(transport).newStream(same(method), same(metadata), same(callOptions));
669 .newStream(any(MethodDescriptor.class), any(Metadata.class), any(CallOptions.class));
[all...] |
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| CronetClientTransport.java | 111 public CronetClientStream newStream(final MethodDescriptor<?, ?> method, final Metadata headers,
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| NettyClientTransport.java | 150 public ClientStream newStream(
|
| /external/syzkaller/vendor/google.golang.org/grpc/transport/ |
| http2_client.go | 317 func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr) *Stream {
500 // NewStream creates a stream and registers it into the transport as "active"
502 func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (_ *Stream, err error) {
508 s := t.newStream(ctx, callHdr)
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| StreamAllocation.java | 64 * #newStream newStream()}.
91 public HttpStream newStream(int connectTimeout, int readTimeout, int writeTimeout,
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/http/ |
| StreamAllocation.java | 65 * #newStream newStream()}.
93 public HttpStream newStream(int connectTimeout, int readTimeout, int writeTimeout,
|
| /external/antlr/runtime/Python/unittests/ |
| testtree.py | 19 def newStream(self, t):
27 stream = self.newStream(t)
76 stream = self.newStream(t)
145 stream = self.newStream(t)
162 stream = self.newStream(t)
[all...] |
| /external/antlr/runtime/Python3/unittests/ |
| testtree.py | 18 def newStream(self, t):
26 stream = self.newStream(t)
73 stream = self.newStream(t)
142 stream = self.newStream(t)
159 stream = self.newStream(t)
[all...] |
| /device/generic/goldfish/camera/ |
| EmulatedFakeCamera2.cpp | 455 Stream newStream;
456 newStream.ops = stream_ops;
457 newStream.width = width;
458 newStream.height = height;
459 newStream.format = format;
461 newStream.stride = width;
463 mStreams.add(mNextStreamId, newStream);
580 ReprocessStream newStream;
581 newStream.ops = stream_ops;
582 newStream.width = baseStream.width
[all...] |
| /device/google/cuttlefish_common/guest/hals/camera/ |
| EmulatedFakeCamera2.cpp | 468 Stream newStream;
469 newStream.ops = stream_ops;
470 newStream.width = width;
471 newStream.height = height;
472 newStream.format = format;
474 newStream.stride = width;
476 mStreams.add(mNextStreamId, newStream);
592 ReprocessStream newStream;
593 newStream.ops = stream_ops;
594 newStream.width = baseStream.width
[all...] |
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| server.go | 361 // Write deadlines are set per stream in serverConn.newStream.
[all...] |
| transport.go | 828 cs := cc.newStream()
[all...] |
