Struct StreamRestore

pub struct StreamRestore { /* private fields */ }

A wrapper object providing stream restore routines to a context.

Note: Saves a copy of active multi-use closure callbacks, which it frees on drop.

Implementations

impl StreamRestore

pub fn test<F>(&mut self, callback: F) -> Operation<dyn FnMut(u32)>

where F: FnMut(u32) + 'static,

Tests if this extension module is available in the server.

Panics if the underlying C function returns a null pointer.

pub fn read<F>( &mut self, callback: F, ) -> Operation<dyn FnMut(ListResult<&Info<'_>>)>

where F: FnMut(ListResult<&Info<'_>>) + 'static,

Reads all entries from the stream database.

Panics if the underlying C function returns a null pointer.

pub fn write<F>( &mut self, mode: UpdateMode, data: &[&Info<'_>], apply_immediately: bool, callback: F, ) -> Operation<dyn FnMut(bool)>

where F: FnMut(bool) + 'static,

Stores entries in the stream database.

The callback must accept a bool, which indicates success.

Panics if the underlying C function returns a null pointer, or if the length of the array is too long to be communicated to the C function.

pub fn delete<F>( &mut self, streams: &[&str], callback: F, ) -> Operation<dyn FnMut(bool)>

where F: FnMut(bool) + 'static,

Deletes entries from the stream database.

The callback must accept a bool, which indicates success.

Panics if the underlying C function returns a null pointer.

pub fn subscribe<F>( &mut self, enable: bool, callback: F, ) -> Operation<dyn FnMut(bool)>

where F: FnMut(bool) + 'static,

Subscribes to changes in the stream database.

The callback must accept a bool, which indicates success.

Panics if the underlying C function returns a null pointer.

pub fn set_subscribe_cb<F>(&mut self, callback: F)

where F: FnMut() + 'static,

Sets the subscription callback that is called when subscribe() was called.

Trait Implementations

impl Drop for StreamRestore

fn drop(&mut self)

Executes the destructor for this type.

impl Send for StreamRestore

impl Sync for StreamRestore