Module: Gritz::Call

Included in:
Testing::InMemoryCall
Defined in:
/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb

Overview

Contract implemented by transports and in-memory RPC calls.

Instance Method Summary collapse

Instance Method Details

#cancelled? ⇒ Boolean

Returns:

  • (Boolean) 


12
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 12

def cancelled? = false

#deadline ⇒ Object 



9
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 9

def deadline = nil

#each_message ⇒ Object 



19
20
21
22
23
24
25
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 19

def each_message
  return enum_for(__method__) unless block_given?

  while (message = read)
    yield message
  end
end

#merge_initial_metadata(metadata = {}) ⇒ Object 



16
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 16

def merge_initial_metadata(metadata = {}) = send_initial_metadata(metadata)

#metadata ⇒ Object

Raises:

  • (NotImplementedError) 


8
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 8

def metadata = raise NotImplementedError

#method_descriptor ⇒ Object

Raises:

  • (NotImplementedError) 


7
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 7

def method_descriptor = raise NotImplementedError

#peer ⇒ Object 



10
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 10

def peer = nil

#peer_identity ⇒ Object 



11
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 11

def peer_identity = nil

#read ⇒ Object

Raises:

  • (NotImplementedError) 


13
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 13

def read = raise NotImplementedError

#send_initial_metadata(metadata = {}) ⇒ Object

Raises:

  • (NotImplementedError) 


15
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 15

def send_initial_metadata(metadata = {}) = raise NotImplementedError

#trailing_metadata ⇒ Object

Raises:

  • (NotImplementedError) 


17
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 17

def trailing_metadata = raise NotImplementedError

#write(message) ⇒ Object

Raises:

  • (NotImplementedError) 


14
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/call.rb', line 14

def write(message) = raise NotImplementedError