Module: Hakuban::Stream

Included in:: ObjectExposeContract, ObjectObserveContract, ObjectStateSink, ObjectStateStream, TagExposeContract, TagObserveContract

Defined in:: lib/hakuban/stream.rb

Defined Under Namespace

Classes: KilledOnNext, StreamEnumerator

Instance Method Summary collapse

#each(*args, **kwargs, &block) ⇒ Object

Instance Method Details

#each(*args, **kwargs, &block) ⇒ `Object`



6
7
8

# File 'lib/hakuban/stream.rb', line 6

def each(*args,**kwargs,&block)
	StreamEnumerator.new(self,false,false,false,args,kwargs).call_or_return(&block)
end