Implement slidingWindow in Observable