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