Class: Gritz::Testing::InMemoryCall

Inherits:
Object
  • Object
show all
Includes:
Call
Defined in:
/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb

Overview

Runs all RPC shapes without sockets or grpc initialization.

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Call

#each_message

Constructor Details

#initialize(method_descriptor:, messages:, metadata: {}, deadline: nil, peer: nil, peer_identity: nil) ⇒ InMemoryCall

Returns a new instance of InMemoryCall.



13
14
15
16
17
18
19
20
21
22
23
24
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 13

def initialize(method_descriptor:, messages:, metadata: {}, deadline: nil, peer: nil, peer_identity: nil)
  @method_descriptor = method_descriptor
  @messages = messages.to_enum
  @metadata = metadata
  @deadline = deadline
  @peer = peer
  @peer_identity = peer_identity
  @responses = []
  @initial_metadata = {}
  @trailing_metadata = {}
  @cancelled = false
end

Instance Attribute Details

#deadline ⇒ Object (readonly) 



10
11
12
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 10

def deadline
  @deadline
end

#initial_metadata ⇒ Object (readonly) 



10
11
12
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 10

def initial_metadata
  @initial_metadata
end

#metadata ⇒ Object (readonly) 



10
11
12
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 10

def metadata
  @metadata
end

#method_descriptor ⇒ Object (readonly) 



10
11
12
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 10

def method_descriptor
  @method_descriptor
end

#peer ⇒ Object (readonly) 



10
11
12
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 10

def peer
  @peer
end

#peer_identity ⇒ Object (readonly) 



10
11
12
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 10

def peer_identity
  @peer_identity
end

#responses ⇒ Object (readonly) 



10
11
12
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 10

def responses
  @responses
end

#trailing_metadata ⇒ Object (readonly) 



10
11
12
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 10

def trailing_metadata
  @trailing_metadata
end

Instance Method Details

#cancel! ⇒ Object 



36
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 36

def cancel! = @cancelled = true

#cancelled? ⇒ Boolean

Returns:

  • (Boolean) 


35
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 35

def cancelled? = @cancelled

#read ⇒ Object 



26
27
28
29
30
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 26

def read
  @messages.next
rescue StopIteration
  nil
end

#send_initial_metadata(metadata = {}) ⇒ Object Also known as: merge_initial_metadata 



33
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 33

def send_initial_metadata(metadata = {}) = @initial_metadata.merge!(metadata)

#write(message) ⇒ Object 



32
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/testing/in_memory_call.rb', line 32

def write(message) = @responses << message