Struct tarantool_rs::Stream

pub struct Stream { /* private fields */ }

Abstraction, providing sequential processing of requests.

With streams there is a guarantee that the server instance will not handle the next request in a stream until it has completed the previous one (docs).

Example

use tarantool_rs::{Connection, ConnectionLike};

let connection = Connection::builder().build("localhost:3301").await.unwrap();

// This will print 'fast' and then 'slow'
let eval_slow_fut = connection
    .eval::<_, Value>("fiber = require('fiber'); fiber.sleep(0.5); return ...;", vec!["slow".into()])
    .inspect(|res| println!("{:?}", res));
let eval_fast_fut = connection
    .eval::<_, Value>("return ...;", vec!["fast".into()])
    .inspect(|res| println!("{:?}", res));
let _ = tokio::join!(eval_slow_fut, eval_fast_fut);

// This will print 'slow' and then 'fast', since slow request was created first and have smaller sync
let stream = connection.stream();
let eval_slow_fut = stream
    .eval::<_, Value>("fiber = require('fiber'); fiber.sleep(0.5); return ...;", vec!["slow".into()])
    .inspect(|res| println!("{:?}", res));
let eval_fast_fut = stream
    .eval::<_, Value>("return ...;", vec!["fast".into()])
    .inspect(|res| println!("{:?}", res));
let _ = tokio::join!(eval_slow_fut, eval_fast_fut);

Trait Implementations

impl Clone for Stream

fn clone(&self) -> Stream

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ConnectionLike for Stream

fn send_request<'life0, 'async_trait>( &'life0 self, body: impl 'async_trait + RequestBody ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Send request, receiving raw response body.

fn stream(&self) -> Stream

Get new Stream.

fn transaction_builder(&self) -> TransactionBuilder

Prepare TransactionBuilder, which can be used to override parameters and create Transaction.

fn transaction<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Transaction, Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Create Transaction with parameters from builder.

fn ping<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Send PING request (docs).

fn eval<'life0, 'async_trait, I, T>( &'life0 self, expr: I, args: Vec<Value> ) -> Pin<Box<dyn Future<Output = Result<T, Error>> + 'async_trait>>where I: Into<Cow<'static, str>> + Send + 'async_trait, T: DeserializeOwned + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn call<'life0, 'async_trait, I, T>( &'life0 self, function_name: I, args: Vec<Value> ) -> Pin<Box<dyn Future<Output = Result<T, Error>> + 'async_trait>>where I: Into<Cow<'static, str>> + Send + 'async_trait, T: DeserializeOwned + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn select<'life0, 'async_trait, T>( &'life0 self, space_id: u32, index_id: u32, limit: Option<u32>, offset: Option<u32>, iterator: Option<IteratorType>, keys: Vec<Value> ) -> Pin<Box<dyn Future<Output = Result<Vec<T>, Error>> + 'async_trait>>where T: DeserializeOwned + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn insert<'life0, 'async_trait>( &'life0 self, space_id: u32, tuple: Vec<Value> ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn update<'life0, 'async_trait>( &'life0 self, space_id: u32, index_id: u32, index_base: Option<u32>, keys: Vec<Value>, tuple: Vec<Value> ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn upsert<'life0, 'async_trait>( &'life0 self, space_id: u32, index_base: u32, ops: Vec<Value>, tuple: Vec<Value> ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn replace<'life0, 'async_trait>( &'life0 self, space_id: u32, keys: Vec<Value> ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn delete<'life0, 'async_trait>( &'life0 self, space_id: u32, index_id: u32, keys: Vec<Value> ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,