Class: StreamEnumerator

Inherits:
Object
  • Object
show all
Defined in:
lib/gitlab/secret_detection/grpc/scanner_service.rb

Overview

StreamEnumerator is used for Bi-directional streaming of requests by returning stream of responses.

Instance Method Summary collapse

Constructor Details

#initialize(requests, action) ⇒ StreamEnumerator

Returns a new instance of StreamEnumerator.



16
17
18
19
 
# File 'lib/gitlab/secret_detection/grpc/scanner_service.rb', line 16

def initialize(requests, action)
  @requests = requests
  @request_action = action
end

Instance Method Details

#each_item ⇒ Object 



21
22
23
24
25
26
27
 
# File 'lib/gitlab/secret_detection/grpc/scanner_service.rb', line 21

def each_item
  return enum_for(:each_item) unless block_given?

  @requests.each do |req|
    yield @request_action.call(req)
  end
end