io.lettuce.core

Interface Subscription

All Superinterfaces:

AutoCloseable, Closeable

public interface Subscription
extends Closeable

Handle to a callback subscription on a Lettuce streaming SPI, such as EventBus.subscribe(java.util.function.Consumer). Closing the subscription stops delivery of further values to the registered callback.

This is not related to org.reactivestreams.Subscription or to Redis Pub/Sub channel subscriptions.

Since:

7.8

Author:

Aleksandar Todorov

Method Summary

Modifier and Type	Method and Description
void	close() Stops delivering to the registered callback.

Method Detail

close

void close()

Stops delivering to the registered callback. Idempotent; calling it more than once has no further effect and never throws.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable