new code_model_flows_processors_db_DbSqlCursor( results, // scala.collection.immutable.Stream[Any] sqlType, // int )