Imap processing using a streaming data model - View it on GitHub