subscribe_to_stream

Build subscribe-to-stream requests.

This module contains the sans-IO request builder for persistent gRPC reads against one stream. Response decoding is shared with kurrentdb/operation/read_stream.

Types

Configuration

opaque

Configuration for subscribing to a single stream.

pub opaque type Configuration

Values

configure

pub fn configure() -> Configuration

Create subscription configuration with default values.

Defaults are forwards, from the end of the stream, and link resolution disabled.

direction

pub fn direction(
  config: Configuration,
  direction: read_stream.Direction,
) -> Configuration

Set the subscription read direction.

from_revision

pub fn from_revision(
  config: Configuration,
  revision: read_stream.ReadRevision,
) -> Configuration

Set the revision from which the subscription should start.

request

pub fn request(
  client: kurrentdb.Client,
  stream stream_name: String,
  config config: Configuration,
) -> request.Request(BitArray)

Build a Streams/Read subscription request for a single stream.

The returned request starts a streaming response. Backends should decode each gRPC message with read_stream.decode_message.

resolve_links

pub fn resolve_links(
  config: Configuration,
  resolve_links: Bool,
) -> Configuration

Enable or disable link-to-event resolution.