pub fn extract_stream_item(ty: &Type) -> Option<Type>
Check if a type is impl Stream<Item=T> and extract T