com.mulesoft.connectors.internal.source.pagination

Class BatchPageProvider<T>

java.lang.Object

com.mulesoft.connectors.internal.source.pagination.BatchPageProvider<T>

All Implemented Interfaces:

org.mule.runtime.extension.api.runtime.streaming.PagingProvider<ExtendedOAuthRestConnection,org.mule.runtime.extension.api.runtime.operation.Result<T,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

public class BatchPageProvider<T>
extends Object
implements org.mule.runtime.extension.api.runtime.streaming.PagingProvider<ExtendedOAuthRestConnection,org.mule.runtime.extension.api.runtime.operation.Result<T,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

Field Summary

Fields

Modifier and Type	Field and Description
protected GmailConfiguration	config

Constructor Summary

Constructors

Constructor and Description
BatchPageProvider(GmailConfiguration config, int batchSize, List<org.mule.runtime.http.api.domain.message.request.HttpRequest> requests, Class<T> mappedClass)

Method Summary

Modifier and Type	Method and Description
void	close(ExtendedOAuthRestConnection connection)
List<org.mule.runtime.extension.api.runtime.operation.Result<T,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>	getPage(ExtendedOAuthRestConnection connection)
Optional<Integer>	getTotalResults(ExtendedOAuthRestConnection connection)
boolean	hasNext()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.mule.runtime.extension.api.runtime.streaming.PagingProvider

useStickyConnections

Field Detail

config

protected final GmailConfiguration config

Constructor Detail

BatchPageProvider

public BatchPageProvider(GmailConfiguration config,
                         int batchSize,
                         List<org.mule.runtime.http.api.domain.message.request.HttpRequest> requests,
                         Class<T> mappedClass)

Method Detail

getPage

public List<org.mule.runtime.extension.api.runtime.operation.Result<T,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>> getPage(ExtendedOAuthRestConnection connection)

Specified by:

getPage in interface org.mule.runtime.extension.api.runtime.streaming.PagingProvider<ExtendedOAuthRestConnection,org.mule.runtime.extension.api.runtime.operation.Result<T,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

getTotalResults

public Optional<Integer> getTotalResults(ExtendedOAuthRestConnection connection)

Specified by:

getTotalResults in interface org.mule.runtime.extension.api.runtime.streaming.PagingProvider<ExtendedOAuthRestConnection,org.mule.runtime.extension.api.runtime.operation.Result<T,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

close

public void close(ExtendedOAuthRestConnection connection)
           throws org.mule.runtime.api.exception.MuleException

Specified by:

close in interface org.mule.runtime.extension.api.runtime.streaming.PagingProvider<ExtendedOAuthRestConnection,org.mule.runtime.extension.api.runtime.operation.Result<T,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

Throws:

org.mule.runtime.api.exception.MuleException

hasNext

public boolean hasNext()