public Observable<ServiceResponse<Page<JobStreamInner>>> listByJobWithServiceResponseAsync(final String resourceGroupName, final String automationAccountName, final String jobId) {
        return listByJobSinglePageAsync(resourceGroupName, automationAccountName, jobId)
            .concatMap(new Func1<ServiceResponse<Page<JobStreamInner>>, Observable<ServiceResponse<Page<JobStreamInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<JobStreamInner>>> call(ServiceResponse<Page<JobStreamInner>> page) {
                    String nextPageLink = page.body().nextPageLink();
                    if (nextPageLink == null) {
                        return Observable.just(page);
                    }
                    return Observable.just(page).concatWith(listByJobNextWithServiceResponseAsync(nextPageLink));
                }
            });
    }
public Observable < ServiceResponse < Page < JobStreamInner > > > listByJobWithServiceResponseAsync ( final String resourceGroupName , final String automationAccountName , final String jobId ) { return listByJobSinglePageAsync ( resourceGroupName , automationAccountName , jobId ) . concatMap ( new Func1 < ServiceResponse < Page < JobStreamInner > > , Observable < ServiceResponse < Page < JobStreamInner > > > > ( ) { @ Override public Observable < ServiceResponse < Page < JobStreamInner > > > call ( ServiceResponse < Page < JobStreamInner > > page ) { String nextPageLink = page . body ( ) . nextPageLink ( ) ; if ( nextPageLink == null ) { return Observable . just ( page ) ; } return Observable . just ( page ) . concatWith ( listByJobNextWithServiceResponseAsync ( nextPageLink ) ) ; } } ) ; }
Retrieve a list of jobs streams identified by job id.

@param resourceGroupName Name of an Azure Resource group.
@param automationAccountName The name of the automation account.
@param jobId The job Id.
@throws IllegalArgumentException thrown if parameters fail the validation
@return the observable to the PagedList&lt;JobStreamInner&gt; object