refactor in stream source core; added twitter streamer