A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
R
S
T
U
V
W
R
- readAllBytes() - function in eu.vstoyanov.natsy.jetstream.model.ObjectResult
- Read all data from the object as a byte arrayWARNING: This loads the entire object into memory.
- register(kotlin.reflect.KClass,eu.vstoyanov.natsy.codec.MessageCodec) - function in eu.vstoyanov.natsy.codec.CodecRegistry.Builder
- Register a custom codec
- register(eu.vstoyanov.natsy.codec.CodecRegistry.Builder,eu.vstoyanov.natsy.codec.MessageCodec) - function in eu.vstoyanov.natsy.codec.CodecRegistryKt
- registerJson(kotlin.reflect.KClass,kotlinx.serialization.KSerializer) - function in eu.vstoyanov.natsy.codec.CodecRegistry.Builder
- Register a JSON codec for a specific type using kotlinx.
- registerJson(eu.vstoyanov.natsy.codec.CodecRegistry.Builder,kotlinx.serialization.KSerializer) - function in eu.vstoyanov.natsy.codec.CodecRegistryKt
- remainingDeliveries(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
- Calculate remaining delivery attempts
- ReplayPolicy - class in eu.vstoyanov.natsy.jetstream
- Consumer replay policy
- request(java.lang.String,Req,kotlin.reflect.KClass,kotlin.reflect.KClass,kotlin.time.Duration) - function in eu.vstoyanov.natsy.NatsScope
- Request-reply pattern with typed messagesUses Dispatchers.IO because connection.request() blocks waiting for response.
- request(java.lang.String,Req,kotlin.time.Duration) - function in eu.vstoyanov.natsy.NatsScope
- Request-reply with reified type parameters for better ergonomics
- requestMany(java.lang.String,Req,java.lang.Integer,kotlin.time.Duration) - function in eu.vstoyanov.natsy.NatsScope
- Request-many with reified type parameters for better ergonomics
- requestMany(java.lang.String,Req,kotlin.reflect.KClass,kotlin.reflect.KClass,java.lang.Integer,kotlin.time.Duration) - function in eu.vstoyanov.natsy.NatsScope
- Request-many pattern (scatter-gather)Sends a request to multiple responders and collects all responses until timeout or expectedResponses count is reached.
- requireCodec(kotlin.reflect.KClass) - function in eu.vstoyanov.natsy.codec.CodecRegistry
- Get the codec for a specific Kotlin type, or fail naming the type and its registration.
- resume() - function in eu.vstoyanov.natsy.jetstream.ConsumerContext
- Resume the consumerResumes message delivery to a paused consumer.
- RetentionPolicy - class in eu.vstoyanov.natsy.jetstream
- Stream retention policy