Replace stub Poll::Pending with actual stream polling that reads from underlying data source and converts DBN messages to MarketEvents. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>