Package vn.payos.core

Class AsyncAutoPager<Item>

java.lang.Object

vn.payos.core.AsyncAutoPager<Item>

All Implemented Interfaces:

AsyncStreamResponse<Item>

public class AsyncAutoPager<Item>
extends Object
implements AsyncStreamResponse<Item>

AsyncAutoPager

Nested Class Summary

Nested classes/interfaces inherited from interface vn.payos.core.AsyncStreamResponse

AsyncStreamResponse.Handler<T>, AsyncStreamResponse.State

Constructor Summary

Constructors

Constructor	Description
AsyncAutoPager(PageAsync<Item> initialPage)	AsyncAutoPager
AsyncAutoPager(PageAsync<Item> initialPage, Executor defaultExecutor)	AsyncAutoPager

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this resource, relinquishing any underlying resources.
CompletableFuture<Void>	onCompleteFuture()	Returns a future that completes when a stream is fully consumed, errors, or gets closed early.
AsyncStreamResponse<Item>	subscribe(AsyncStreamResponse.Handler<Item> handler)	Registers handler to be called for events of this stream.
AsyncStreamResponse<Item>	subscribe(AsyncStreamResponse.Handler<Item> handler, Executor executor)	Registers handler to be called for events of this stream.

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncAutoPager

public AsyncAutoPager(PageAsync<Item> initialPage)

AsyncAutoPager

Parameters:

initialPage - initial page

AsyncAutoPager

public AsyncAutoPager(PageAsync<Item> initialPage,
 Executor defaultExecutor)

AsyncAutoPager

Parameters:

initialPage - initial page

defaultExecutor - default executor

Method Details

subscribe

public AsyncStreamResponse<Item> subscribe(AsyncStreamResponse.Handler<Item> handler)

Description copied from interface: AsyncStreamResponse

Registers handler to be called for events of this stream.

Handler's methods will be called in the client's configured or default thread pool.

Specified by:

subscribe in interface AsyncStreamResponse<Item>

Parameters:

handler - Handler to process items and completion events

Returns:

this AsyncStreamResponse for chaining

subscribe

public AsyncStreamResponse<Item> subscribe(AsyncStreamResponse.Handler<Item> handler,
 Executor executor)

Description copied from interface: AsyncStreamResponse

Registers handler to be called for events of this stream.

Handler's methods will be called in the given executor.

Specified by:

subscribe in interface AsyncStreamResponse<Item>

Parameters:

handler - Handler to process items and completion events

executor - Executor to run handler methods in

Returns:

this AsyncStreamResponse for chaining

onCompleteFuture

public CompletableFuture<Void> onCompleteFuture()

Description copied from interface: AsyncStreamResponse

Returns a future that completes when a stream is fully consumed, errors, or gets closed early.

Specified by:

onCompleteFuture in interface AsyncStreamResponse<Item>

Returns:

CompletableFuture for completion tracking

close

public void close()

Description copied from interface: AsyncStreamResponse

Closes this resource, relinquishing any underlying resources.

This is purposefully not inherited from AutoCloseable because this response should not be synchronously closed via try-with-resources.

Specified by:

close in interface AsyncStreamResponse<Item>