Current implementation is for Unary methods only. Need to add support for streaming aggregation as well.