The current API is defined only on List<object>. Create and implement moving averages on Stream<object>.