handling of streaming of records