S-index

A B C D E F G H I J K L M N O P R S T U V W

S

S2 - enum entry in eu.vstoyanov.natsy.jetstream.CompressionOption

Compress stored messages with S2

setAckPolicy(eu.vstoyanov.natsy.jetstream.model.AckPolicy) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Acknowledgment policy for message processing

setAckWait(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

How long to wait for acknowledgment before redelivering

setAllowDirect(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Serve reads straight from the stream, without a consumerWhat makes getMessage-shaped lookups and a mirror's local reads a single round trip rather than a consumer created and torn down per call.

setApiPrefix(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder

Non-default JetStream API subject prefix, as JetStreamOptions.prefixThis is the subject every JetStream API call is addressed to, which is how a client reaches JetStream in another account.

setBackoff(java.util.List) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

How long to wait before each redelivery, instead of a fixed ackWaitThe standard poison-message mitigation: listOf(1.seconds, 5.seconds, 30.seconds) retries quickly for a blip and slowly for an outage, and with maxDeliver set it bounds how long a message can keep failing before it is dead-lettered.

setCluster(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.PlacementConfigBuilder

Cluster name where the object store should be placed

setCluster(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.PlacementBuilder

Cluster name where the stream should be placed

setCompression(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder

Whether the bucket's messages are stored S2-compressed Default: false (no compression)Only read when the bucket is created: natsy leaves an existing bucket's configuration alone.

setCompressionOption(eu.vstoyanov.natsy.jetstream.CompressionOption) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Whether stored messages are compressedFile storage only; a memory stream ignores it.

setConnectionListener(io.nats.client.ConnectionListener) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setConnectionTimeout(kotlin.time.Duration) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setCredentialsPath(java.lang.String) - function in eu.vstoyanov.natsy.KlientConfigBuilder

Path to a NATS credentials file - the .creds holding a user JWT and its NKey seedA path, not the credential material itself: jnats reads the file on every connect and reconnect, so a rotated file is picked up without rebuilding the klient.

setDefaultAckWait(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder

Default acknowledgment wait time for consumers

setDefaultMaxDeliver(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder

Default maximum delivery attempts (-1 for unlimited)

setDefaultReplayPolicy(eu.vstoyanov.natsy.jetstream.ReplayPolicy) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder

Default replay policy for consumers

setDefaultReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder

Default number of replicas for streams

setDefaultRetentionPolicy(eu.vstoyanov.natsy.jetstream.RetentionPolicy) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder

Default retention policy for streams

setDefaultStorageType(eu.vstoyanov.natsy.jetstream.StorageType) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder

Default storage type for streams

setDeliverGroup(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Deliver group for queue semantics (push consumers only)A deliver group balances among subscribers of one consumer's deliver subject, so it needs a consumer every collector can share - however the group was asked for.

setDeliverPolicy(eu.vstoyanov.natsy.jetstream.model.DeliverPolicy) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Deliver policy determines where to start consuming messages

setDeliverSubject(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Deliver subject for push consumers

setDenyDelete(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Refuse per-message deletes on this stream

setDenyPurge(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Refuse purges on this stream

setDescription(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Description of the consumer

setDescription(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder

Optional description of the bucket

setDescription(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder

Description of the bucket

setDescription(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Description of the stream

setDestination(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.RepublishBuilder

Subject template the copy is published toSupports the $1, $2 … tokens matched by wildcards in source, so source = "orders.*" with destination = "mirror.$1" sends orders.created on to mirror.created.

setDiscardMessagesWhenOutgoingQueueFull(java.lang.Boolean) - function in eu.vstoyanov.natsy.KlientConfigBuilder

Whether a publish that finds the outgoing queue full drops the message instead of waitingThe queue being full means the connection cannot write as fast as the application publishes.

setDiscardPolicy(eu.vstoyanov.natsy.jetstream.model.DiscardPolicy) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Discard policy when limits are reached

setDomain(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder

JetStream domain name for multi-tenancy

setDuplicateWindow(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Window within which to track duplicate messages

setDurable(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Durable name for the consumer If null, the consumer will be ephemeral

setErrorListener(io.nats.client.ErrorListener) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setExpectedLastMsgId(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations

Expected last message ID for ordering validation

setExpectedLastSequence(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations

Expected last sequence number in the stream

setExpectedLastSubjectSequence(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations

Expected last sequence number for this specific subject

setExpectedStream(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations

Expected stream name - validates publish went to correct stream

setExternalApiPrefix(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder

External API prefix for external sources

setExternalDeliverPrefix(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder

External deliver prefix for external sources

setFilterSubject(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Filter messages by subjectOne subject; use filterSubjects for several.

setFilterSubject(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder

Optional subject filter for the source stream

setFilterSubjects(java.util.List) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Filter messages by several subjectsThe plural form of filterSubject; a consumer over orders.created and orders.cancelled without the orders.updated in between.

setFlowControl(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Enable flow control for push consumersFlow control prevents the server from overwhelming slow consumers.

setHeadersOnly(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Deliver only headers, not payloads

setHeadersOnly(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.model.RepublishBuilder

Republish the headers without the body

setIdleHeartbeat(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Idle heartbeat interval for push consumersThe server will send heartbeat messages if no data messages are sent within this interval.

setInactiveThreshold(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Inactivity threshold before consumer is considered inactive

setIoDispatcher(kotlinx.coroutines.CoroutineDispatcher) - function in eu.vstoyanov.natsy.KlientConfigBuilder

The dispatcher every blocking NATS call runs onjnats is a blocking client: management calls, key-value and object-store operations, flushes and fetches all park a thread, so natsy moves them off the caller's.

setMaxAckPending(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Maximum number of outstanding unacknowledged messages

setMaxAge(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Maximum age of messages to retain (Duration.

setMaxBatch(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Largest batch a single pull request may ask this consumer fornull - the default - leaves the limit to the server, which does not cap batches.

setMaxBucketSize(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder

Maximum number of bytes for the entire bucket Default: -1 (unlimited)

setMaxBucketSize(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder

Maximum size of the bucket in bytes (default: -1 = unlimited)

setMaxBytes(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Maximum total bytes to retain (-1 for unlimited)

setMaxConsumers(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Maximum number of consumers allowed on this stream (-1 for unlimited)

setMaxDeliver(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Maximum number of delivery attempts (-1 for unlimited)

setMaxExpires(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Longest a pull request against this consumer may waitZERO - the default - leaves the limit to the server.

setMaxHistoryPerKey(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder

Maximum number of history entries per key (includes current value) Default: 1 (only keep current value) Set to higher value to track history of changes

setMaxMessages(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Maximum number of messages to retain (-1 for unlimited)

setMaxMessagesInOutgoingQueue(java.lang.Integer) - function in eu.vstoyanov.natsy.KlientConfigBuilder

How many messages may wait in the connection's outgoing queuenull leaves jnats' default (5000).

setMaxMessagesPerSubject(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Maximum messages per subject (-1 for unlimited)

setMaxMsgSize(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Maximum size of a single message (-1 for unlimited)

setMaxPullWaiting(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Maximum number of pull requests that may wait on the consumer at oncenull - the default - leaves the limit to the server, which allows 512.

setMaxReconnects(java.lang.Integer) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setMaxValueSize(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder

Maximum size in bytes for a single value Default: -1 (server default, typically 1MB)

setMemoryStorage(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Enable memory storage for the consumer state

setMessageId(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations

Message ID for the current message (deduplication)

setMetadata(java.util.Map) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Free-form key-value pairs stored on the consumerFor whoever has to work out later which deployment created it.

setName(java.lang.String) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setName(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Name for the consumer, without making it durableA named consumer is still ephemeral - the server reaps it once inactiveThreshold passes - but it is addressable and re-attachable in the meantime, where an unnamed one gets a server-generated name nobody can predict.

setName(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder

Name of the source stream

setNoAck(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Disable acknowledgments (used for fire-and-forget scenarios)

setPassword(kotlin.CharArray) - function in eu.vstoyanov.natsy.KlientConfigBuilder

Password for username, held the way token is

setPingInterval(kotlin.time.Duration) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setRateLimit(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Rate limit in bits per second (-1 for unlimited)

setReconnectBufferSize(java.lang.Integer) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setReconnectOnConnect(java.lang.Boolean) - function in eu.vstoyanov.natsy.KlientConfigBuilder

Whether NatsKlient.connect waits for a server that is not up yetWith the default false, connecting is a single pass over servers: it either succeeds or throws, which is what a fail-fast startup wants.

setReconnectWait(kotlin.time.Duration) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setReplayPolicy(eu.vstoyanov.natsy.jetstream.ReplayPolicy) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Replay policy for message delivery

setReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Number of replicas for the consumer (-1 for stream default)

setReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder

Number of replicas for the bucket (cluster mode) Default: 1 (single replica)For high availability, set to 3 or more (odd numbers recommended)

setReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder

Number of replicas (default: 1)

setReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Number of replicas for the stream (1-5)

setRequestCleanupInterval(kotlin.time.Duration) - function in eu.vstoyanov.natsy.KlientConfigBuilder

How often the connection reaps unanswered request inboxesA JetStream publish future has no per-call deadline of its own: jnats hands it a null timeout (NatsJetStream.java:171) and falls back to this interval (NatsConnection.java:1484-1486).

setRequestTimeout(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder

How long a JetStream API call waits for the server, including a publish waiting for its ackA publish is awaited against this deadline, but the future jnats actually uses is cleaned up on eu.vstoyanov.natsy.KlientConfigBuilder.requestCleanupInterval.

setRetentionPolicy(eu.vstoyanov.natsy.jetstream.RetentionPolicy) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Retention policy for the stream

setSampleFrequency(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Sample frequency for metrics (0-100, 0 = disabled)

setServers(java.util.List) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setSource(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.RepublishBuilder

Subject filter selecting which published messages are republishednull - the default - republishes everything the stream captures.

setStackTrace(kotlin.Array) - function in kotlin.Throwable

setStartSequence(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Start sequence for BY_START_SEQUENCE deliver policy

setStartTime(java.time.ZonedDateTime) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Start time for BY_START_TIME deliver policy

setStorageType(eu.vstoyanov.natsy.jetstream.StorageType) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder

Storage type for the bucket Default: StorageType.FILE for persistence

setStorageType(eu.vstoyanov.natsy.jetstream.StorageType) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder

Storage type for the bucket Default: StorageType.FILE for persistence

setStorageType(eu.vstoyanov.natsy.jetstream.StorageType) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Storage type for the stream

setSubjects(java.util.List) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

List of subjects this stream listens toSupports wildcards (e.g., "orders.*", "payments.>").

setTags(java.util.List) - function in eu.vstoyanov.natsy.jetstream.PlacementConfigBuilder

Tags for placement (e.g.

setTags(java.util.List) - function in eu.vstoyanov.natsy.jetstream.model.PlacementBuilder

List of tags for placement constraints

setTlsContext(javax.net.ssl.SSLContext) - function in eu.vstoyanov.natsy.KlientConfigBuilder

setToken(kotlin.CharArray) - function in eu.vstoyanov.natsy.KlientConfigBuilder

Authentication token, held the way password isCharArray rather than String so the secret can be zeroed after connecting; jnats takes char[] here too and has deprecated its String overload (io/nats/client/Options.java:1952).

setTtl(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder

Time-to-live for entries in the bucket Default: Duration.

setTtl(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder

TTL for objects in the bucket (default: no expiration)

setUsername(java.lang.String) - function in eu.vstoyanov.natsy.KlientConfigBuilder

source(kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Add a source stream for aggregationA stream fed only by sources needs no subjects of its own, the same as a mirror.

started(kotlin.time.Duration) - function in eu.vstoyanov.natsy.SubscriptionHandle

Suspends until this subscription is live on the server: until messages has been collected, registering the SUB, and until the server has acknowledged it.

stats() - function in eu.vstoyanov.natsy.jetstream.ConsumerContext

Everything worth monitoring about this consumer, in one round tripReplaces the six single-value monitors this class used to expose.

status() - function in eu.vstoyanov.natsy.jetstream.KeyValueStore

Get the status of the bucket

status() - function in eu.vstoyanov.natsy.jetstream.ObjectStore

Get the status of the bucket

StorageType - class in eu.vstoyanov.natsy.jetstream

Where a stream or bucket keeps its messagesThe same choice for streams, Key-Value buckets and Object Store buckets - each of the three is a stream underneath.

stream(java.lang.String,kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext

Create or update a JetStream streamIf the stream doesn't exist, a new one is created from the configuration block.

StreamConfig - class in eu.vstoyanov.natsy.jetstream

DSL for configuring JetStream streamsExample usage:

val streamCtx = js.stream("MY_STREAM") {
    subjects = listOf("orders.*", "payments.*")
    retentionPolicy = RetentionPolicy.LIMITS
    maxMessages = 1000000
    maxBytes = 1024 * 1024 * 1024 // 1GB
    storageType = StorageType.FILE
    replicas = 3
}

StreamConfigBuilder - class in eu.vstoyanov.natsy.jetstream

Builder for JetStream stream configuration

StreamContext - class in eu.vstoyanov.natsy.jetstream

Context for JetStream stream operationsProvides access to stream management and operations including:

Stream information and updates
Message purging and deletion
Consumer listing

Every operation reports failure by throwing a eu.vstoyanov.natsy.exception.NatsyException.

streams() - function in eu.vstoyanov.natsy.jetstream.JetStreamContext

List all streams in the JetStream accountReturns a Flow that emits StreamContext for each stream.

StreamSource - class in eu.vstoyanov.natsy.jetstream.model

Stream source configuration for stream aggregationUsed to aggregate messages from other streams or external sources.

StreamSourceBuilder - class in eu.vstoyanov.natsy.jetstream.model

Builder for StreamSource configuration

StringCodec - class in eu.vstoyanov.natsy.codec

Carries a String as raw UTF-8 - no quoting, no escaping, exactly the bytes a nats pub would send.

subscribe(eu.vstoyanov.natsy.NatsOperations,java.lang.String,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.NatsOperationsKt

Subscribe to a subject with typed messagesAny @Serializable type works with no registration; see eu.vstoyanov.natsy.codec.CodecRegistry for what else does and how to override it.

subscribe(java.lang.String,java.lang.String,java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext

Subscribe to a JetStream stream with a push consumerCreates an ephemeral push consumer and returns a Flow of typed messages.

subscribeBytes(java.lang.String,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow) - function in eu.vstoyanov.natsy.NatsKlient

Subscribe to raw messages for performanceThe jnats dispatcher hands messages to a channel of capacity slots without ever suspending.

subscribeBytes(java.lang.String,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow) - function in eu.vstoyanov.natsy.NatsOperations

Subscribe to raw messages for performanceThe jnats dispatcher hands messages to a channel of capacity slots without ever suspending.

subscribeMessages(eu.vstoyanov.natsy.NatsOperations,java.lang.String,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.NatsOperationsKt

Subscribe to a subject with typed messages, keeping the envelopesubscribe with what it leaves out: each message arrives as a TypedMessage carrying the subject it was published to, the subject a reply is expected on, and the headers it came with.

subscribeMessagesTyped(java.lang.String,kotlin.reflect.KType,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.NatsKlient

subscribeMessages with the type to decode into given as a value.

subscribeTyped(java.lang.String,kotlin.reflect.KType,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.NatsKlient

subscribe with the type to decode into given as a value.

SubscriptionHandle - class in eu.vstoyanov.natsy

One subscription, and the rendezvous that tells you it exists.

A B C D E F G H I J K L M N O P R S T U V W