Package ai.fal.client.queue

Class QueueClientImpl

java.lang.Object

ai.fal.client.queue.QueueClientImpl

All Implemented Interfaces:

QueueClient

public class QueueClientImpl
extends Object
implements QueueClient

Constructor Summary

Constructors

Constructor	Description
QueueClientImpl(HttpClient httpClient)

Method Summary

Modifier and Type	Method	Description
<O> Output<O>	result(String endpointId, QueueResultOptions<O> options)	Get the result of a submission.
QueueStatus.StatusUpdate	status(String endpointId, QueueStatusOptions options)	Check the status of a submission.
QueueStatus.InQueue	submit(String endpointId, QueueSubmitOptions options)	Submit a payload to an endpoint's queue.
QueueStatus.Completed	subscribeToStatus(String endpointId, QueueSubscribeOptions options)	Subscribe to the status of a submission.

Methods inherited from class java.lang.Object

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

Constructor Details

QueueClientImpl

public QueueClientImpl(@Nonnull
 HttpClient httpClient)

Method Details

submit

@Nonnull
public QueueStatus.InQueue submit(@Nonnull
 String endpointId,
 @Nonnull
 QueueSubmitOptions options)

Description copied from interface: QueueClient

Submit a payload to an endpoint's queue.

Specified by:

submit in interface QueueClient

Parameters:

endpointId - the endpoint to submit to (e.g. `fal-ai/fast-sdxl`)

options - the submit options

Returns:

the status of the submission with the `requestId` for tracking the submission.

status

@Nonnull
public QueueStatus.StatusUpdate status(@Nonnull
 String endpointId,
 @Nonnull
 QueueStatusOptions options)

Description copied from interface: QueueClient

Check the status of a submission.

Specified by:

status in interface QueueClient

Parameters:

endpointId - the endpoint to cancel the submission for

options - the status check options

Returns:

the status of the submission

subscribeToStatus

@Nonnull
public QueueStatus.Completed subscribeToStatus(@Nonnull
 String endpointId,
 @Nonnull
 QueueSubscribeOptions options)

Description copied from interface: QueueClient

Subscribe to the status of a submission.

Specified by:

subscribeToStatus in interface QueueClient

Parameters:

endpointId - the endpoint to subscribe to the status for

options - the subscribe options

Returns:

the status of the submission

result

@Nonnull
public <O> Output<O> result(@Nonnull
 String endpointId,
 @Nonnull
 QueueResultOptions<O> options)

Description copied from interface: QueueClient

Get the result of a submission.

Specified by:

result in interface QueueClient

Type Parameters:

O - the type of the output payload

Parameters:

endpointId - the endpoint to get the result for

options - the response options

Returns:

the result of the submission