Home
last modified time | relevance | path

Searched refs:serializingExecutor (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java124 private final SerializingExecutor serializingExecutor =
134 serializingExecutor.execute(new Runnable() {
144 serializingExecutor.execute(new Runnable() {
154 serializingExecutor.execute(new Runnable() {
164 serializingExecutor.execute(new Runnable() {
179 serializingExecutor.execute(new Runnable() {
197 serializingExecutor.execute(new Runnable() {
214 serializingExecutor.execute(new Runnable() {
224 serializingExecutor.execute(new Runnable() {
235 serializingExecutor.execute(new Runnable() {
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DRescheduler.java33 private final Executor serializingExecutor; field in Rescheduler
44 Executor serializingExecutor, in Rescheduler() argument
48 this.serializingExecutor = serializingExecutor; in Rescheduler()
80 Rescheduler.this.serializingExecutor.execute(new ChannelFutureRunnable()); in run()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientTransport.java155 private final SerializingExecutor serializingExecutor; field in OkHttpClientTransport
215 serializingExecutor = new SerializingExecutor(executor); in OkHttpClientTransport()
253 serializingExecutor = new SerializingExecutor(executor); in OkHttpClientTransport()
424 frameWriter = new AsyncFrameWriter(this, serializingExecutor); in start()
428 serializingExecutor.execute(new Runnable() { in start()