Struct CallbackSession 

pub struct CallbackSession { /* private fields */ }

A callback-based session for asynchronous operations

Implementations

impl CallbackSession

pub fn command<F>( &self, rql: &str, params: Option<Params>, callback: F, ) -> Result<String, Error>

where F: FnOnce(Result<CommandResult, Error>) + Send + 'static,

Send a command with callback

Examples found in repository

examples/callback_ws.rs (lines 16-23)

fn main() -> Result<(), Box<dyn std::error::Error>> {
	// Connect to ReifyDB server
	let client = Client::ws(("127.0.0.1", 8090))?;

	// Create a callback session with authentication
	let session = client.callback_session(Some("mysecrettoken".to_string()))?;

	// Execute a command to create a table
	let command_id = session.command(
		"CREATE NAMESPACE test; CREATE TABLE test.users { id: INT4, name: UTF8 }",
		None,
		|result| match result {
			Ok(data) => println!("Command executed: {} frames returned", data.frames.len()),
			Err(e) => println!("Command failed: {}", e),
		},
	)?;
	println!("Command sent with ID: {}", command_id);

	// Execute a query
	let query_id = session.query("MAP { x: 42, y: 'hello' }", None, |result| {
		match result {
			Ok(data) => {
				println!("Query executed: {} frames returned", data.frames.len());
				// Print first frame if available
				if let Some(frame) = data.frames.first() {
					println!("First frame:\n{}", frame);
				}
			}
			Err(e) => println!("Query failed: {}", e),
		}
	})?;
	println!("Query sent with ID: {}", query_id);

	// Wait for callbacks to complete
	thread::sleep(Duration::from_millis(500));

	Ok(())
}

pub fn query<F>( &self, rql: &str, params: Option<Params>, callback: F, ) -> Result<String, Error>

where F: FnOnce(Result<QueryResult, Error>) + Send + 'static,

Send a query with callback

Examples found in repository

examples/callback_ws.rs (lines 27-38)

fn main() -> Result<(), Box<dyn std::error::Error>> {
	// Connect to ReifyDB server
	let client = Client::ws(("127.0.0.1", 8090))?;

	// Create a callback session with authentication
	let session = client.callback_session(Some("mysecrettoken".to_string()))?;

	// Execute a command to create a table
	let command_id = session.command(
		"CREATE NAMESPACE test; CREATE TABLE test.users { id: INT4, name: UTF8 }",
		None,
		|result| match result {
			Ok(data) => println!("Command executed: {} frames returned", data.frames.len()),
			Err(e) => println!("Command failed: {}", e),
		},
	)?;
	println!("Command sent with ID: {}", command_id);

	// Execute a query
	let query_id = session.query("MAP { x: 42, y: 'hello' }", None, |result| {
		match result {
			Ok(data) => {
				println!("Query executed: {} frames returned", data.frames.len());
				// Print first frame if available
				if let Some(frame) = data.frames.first() {
					println!("First frame:\n{}", frame);
				}
			}
			Err(e) => println!("Query failed: {}", e),
		}
	})?;
	println!("Query sent with ID: {}", query_id);

	// Wait for callbacks to complete
	thread::sleep(Duration::from_millis(500));

	Ok(())
}

pub fn is_authenticated(&self) -> bool

Check if the session is authenticated

impl CallbackSession

pub fn command_with_handler( &self, rql: &str, params: Option<Params>, handler: impl ResponseHandler + 'static, ) -> Result<String, Error>

Execute command with a response handler

pub fn query_with_handler( &self, rql: &str, params: Option<Params>, handler: impl QueryHandler + 'static, ) -> Result<String, Error>

Execute query with a response handler

Trait Implementations

impl Drop for CallbackSession

fn drop(&mut self)

Executes the destructor for this type.