lib/workato/connector/sdk/streams.rb in workato-connector-sdk-1.3.9 vs lib/workato/connector/sdk/streams.rb in workato-connector-sdk-1.3.10
- old
+ new
@@ -33,10 +33,10 @@
private
sig { params(streams_source: SorbetTypes::SourceHash).void }
def define_action_methods(streams_source)
- streams_source.each do |stream, _stream_proc|
+ streams_source.each_key do |stream|
define_singleton_method(stream) do |input = {}, from = 0, to = nil, frame_size = Stream::DEFAULT_FRAME_SIZE|
to ||= from + frame_size
self[stream].chunk(input, from, to, frame_size)
end