Package org.ngengine.nostr4j.pool

Class NostrPoolAllAckPolicy

java.lang.Object

org.ngengine.nostr4j.pool.NostrPoolAllAckPolicy

All Implemented Interfaces:

Function<List<org.ngengine.platform.AsyncTask<NostrMessageAck>>,NostrMessageAck.Status>, NostrPoolAckPolicy

public class NostrPoolAllAckPolicy
extends Object
implements NostrPoolAckPolicy

Consider a message acknowledged when all acks are received. This is the strictest policy, ensuring that all relays have acknowledged the message. If any ack is pending or fails, the overall status is pending or failure.

Constructor Summary

Constructors

Constructor	Description
NostrPoolAllAckPolicy()

Method Summary

Modifier and Type	Method	Description
NostrMessageAck.Status	apply(List<org.ngengine.platform.AsyncTask<NostrMessageAck>> t)
static NostrPoolAckPolicy	get()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Details

NostrPoolAllAckPolicy

public NostrPoolAllAckPolicy()

Method Details

get

public static NostrPoolAckPolicy get()

apply

public NostrMessageAck.Status apply(List<org.ngengine.platform.AsyncTask<NostrMessageAck>> t)

Specified by:

apply in interface Function<List<org.ngengine.platform.AsyncTask<NostrMessageAck>>,NostrMessageAck.Status>