A construct that continuously watches for items from a stream and invokes the listener code block each time new items are available.