[streaming] Added support for simple types instead of Tuple1 in the API