Update sink stream implementation
Add asynchronously tests for skip stream