Interface ReceiveResult

All Known Implementing Classes:
ReceiveResult.Ended, ReceiveResult.Received, ReceiveResult.TimedOut
public sealed interface ReceiveResult permits ReceiveResult.Received, ReceiveResult.TimedOut, ReceiveResult.Ended
The outcome of one pull receive. A timeout leaves the subscription active; normal termination ends it permanently. Connection termination leaves receiving subscriptions waiting for a later connection. Failures that end the subscription, and interruption, are thrown by PullSubscription.receive(), which lists them.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static final record 
    ReceiveResult.Ended
    The subscription ended through its close, a successful unsubscribe once the deliveries it accepted have been received, or MqttClient.close().
    static final record 
    ReceiveResult.Received
    One delivery handed to this caller.
    static final record 
    ReceiveResult.TimedOut
    No delivery became available before the wait expired.