C E G O S T 
All Classes All Packages

C

CallCounter - Class in com.daml.grpc.adapter
 
CallCounter() - Constructor for class com.daml.grpc.adapter.CallCounter
 
ClientPublisher<Req,​Resp> - Class in com.daml.grpc.adapter.client.rs
RS-gRPC bridge component for server streaming.
ClientPublisher(Req, BiConsumer<Req, StreamObserver<Resp>>, ExecutionSequencerFactory) - Constructor for class com.daml.grpc.adapter.client.rs.ClientPublisher
 
close() - Method in class com.daml.grpc.adapter.SingleThreadExecutionSequencer
 
close() - Method in class com.daml.grpc.adapter.SingleThreadExecutionSequencerPool
 
com.daml.grpc.adapter - package com.daml.grpc.adapter
 
com.daml.grpc.adapter.client.rs - package com.daml.grpc.adapter.client.rs
 
com.daml.grpc.adapter.server.rs - package com.daml.grpc.adapter.server.rs
 
completionFuture - Variable in class com.daml.grpc.adapter.server.rs.ServerSubscriber
 

E

ExecutionSequencer - Interface in com.daml.grpc.adapter
 
ExecutionSequencerFactory - Interface in com.daml.grpc.adapter
Provides means to get ExecutionSequencer instances.

G

getExecutionSequencer() - Method in interface com.daml.grpc.adapter.ExecutionSequencerFactory
 
getExecutionSequencer() - Method in class com.daml.grpc.adapter.SingleThreadExecutionSequencerPool
 
getNewCallId() - Static method in class com.daml.grpc.adapter.CallCounter
 

O

onComplete() - Method in class com.daml.grpc.adapter.server.rs.ServerSubscriber
 
onError(Throwable) - Method in class com.daml.grpc.adapter.server.rs.ServerSubscriber
 
onNext(Resp) - Method in class com.daml.grpc.adapter.server.rs.ServerSubscriber
 
onSubscribe(Subscription) - Method in class com.daml.grpc.adapter.server.rs.ServerSubscriber
 

S

sequence(Runnable) - Method in interface com.daml.grpc.adapter.ExecutionSequencer
Runs the argument asynchronously in an environment that assures the following: - The runnables passed in will be executed one at a time, sequentially.
sequence(Runnable) - Method in class com.daml.grpc.adapter.SingleThreadExecutionSequencer
 
ServerSubscriber<Resp> - Class in com.daml.grpc.adapter.server.rs
 
ServerSubscriber(ServerCallStreamObserver<Resp>, ExecutionSequencer) - Constructor for class com.daml.grpc.adapter.server.rs.ServerSubscriber
 
SingleThreadExecutionSequencer - Class in com.daml.grpc.adapter
Ensures serial execution and thread safety of Runnables by using a single thread underneath.
SingleThreadExecutionSequencerPool - Class in com.daml.grpc.adapter
 
SingleThreadExecutionSequencerPool(String) - Constructor for class com.daml.grpc.adapter.SingleThreadExecutionSequencerPool
 
SingleThreadExecutionSequencerPool(String, int) - Constructor for class com.daml.grpc.adapter.SingleThreadExecutionSequencerPool
 
subscribe(Subscriber<? super Resp>) - Method in class com.daml.grpc.adapter.client.rs.ClientPublisher
Executes the RPC call right away and feeds its results to the subscriber on demand.

T

translateThrowableInOnError(Throwable) - Method in class com.daml.grpc.adapter.server.rs.ServerSubscriber
 
C E G O S T 
All Classes All Packages