class

Moleflow::Api

Inherits GRPC::Service < Reference < Object

Constructors

new(kind : String, config : Config, sources : Array(Source), model : Model)
Source

Instance methods

bidi_streaming?(method : String) : Bool

bidi_streaming? returns true if method is a bidirectional streaming RPC. Generated service base classes override this; the default is false (unary).

Source
busy
Source
dispatch(method : String, request_body : Bytes, ctx : GRPC::ServerContext) : Tuple(Bytes, GRPC::Status)

dispatch routes an incoming unary RPC call to the correct method implementation. Returns {response_body : Bytes, status : Status}.

Source
dispatch_bidi_stream(method : String, requests : GRPC::RawRequestStream, ctx : GRPC::ServerContext, writer : GRPC::RawResponseStream) : GRPC::Status

dispatch_bidi_stream dispatches a bidirectional streaming RPC. requests is a RawRequestStream that yields raw message bytes as they arrive. The transport passes a RawResponseStream; generated subclasses wrap it in a typed ResponseStream(T) before handing off to the user implementation.

Source
dispatch_server_stream(method : String, body : Bytes, ctx : GRPC::ServerContext, writer : GRPC::RawResponseStream) : GRPC::Status

dispatch_server_stream dispatches a server-streaming RPC. The transport passes a RawResponseStream; generated subclasses wrap it in a typed ResponseStream(T) before handing off to the user implementation.

Source
encode(message) : Tuple(Bytes, GRPC::Status)
Source
server_streaming?(method : String) : Bool

server_streaming? returns true if method is a server-streaming RPC. Generated service base classes override this; the default is false (unary).

Source
service_full_name

service_full_name returns the full gRPC service name (e.g. "helloworld.Greeter").

Source
validate_channels(first : UInt32, last : UInt32)
Source