def<\/span> consume<\/span>(<\/span>*<\/span>types<\/span>,<\/span> &<\/span>block<\/span>)<\/span><\/div> filter_types<\/span>(<\/span>types<\/span>)<\/span><\/div> @t<\/span>.<\/span>buf_consumer<\/span>(<\/span>buf_consumer<\/span>)<\/span><\/div> begin<\/span><\/div> while<\/span>(<\/span>true<\/span>)<\/span> do<\/span><\/div> @t<\/span>.<\/span>sleep<\/span> # the tricky little trickster<\/span><\/div> work<\/span> =<\/span> @t<\/span>.<\/span>work<\/span>(<\/span>probe_consumer<\/span>,<\/span> rec_consumer<\/span>(<\/span>block<\/span>))<\/span><\/div> if<\/span> (<\/span>@done<\/span> ||<\/span> work<\/span> ><\/span> 0<\/span>)<\/span><\/div> break<\/span><\/div> end<\/span><\/div> end<\/span><\/div> ensure<\/span><\/div> @t<\/span>.<\/span>stop<\/span><\/div> @t<\/span>.<\/span>work<\/span>(<\/span>probe_consumer<\/span>)<\/span><\/div> end<\/span><\/div>end<\/span><\/div><\/pre><\/div>\n \n <\/div>\n\n